BatchedSubManyEose => BatchedQueryMany
This commit is contained in:
@@ -103,7 +103,7 @@ func (sys *System) batchLoadAddressableEvents(
|
|||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
||||||
// query all relays with the prepared filters
|
// query all relays with the prepared filters
|
||||||
multiSubs := sys.Pool.BatchedSubManyEose(aggregatedContext, relayFilter, nostr.SubscriptionOptions{
|
multiSubs := sys.Pool.BatchedQueryMany(aggregatedContext, relayFilter, nostr.SubscriptionOptions{
|
||||||
Label: "loadaddrs",
|
Label: "loadaddrs",
|
||||||
})
|
})
|
||||||
nextEvent:
|
nextEvent:
|
||||||
|
|||||||
@@ -121,7 +121,7 @@ func (sys *System) batchLoadReplaceableEvents(
|
|||||||
|
|
||||||
// query all relays with the prepared filters
|
// query all relays with the prepared filters
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
multiSubs := sys.Pool.BatchedSubManyEose(aggregatedContext, relayFilter, nostr.SubscriptionOptions{
|
multiSubs := sys.Pool.BatchedQueryMany(aggregatedContext, relayFilter, nostr.SubscriptionOptions{
|
||||||
Label: "repl~" + strconv.Itoa(int(kind)),
|
Label: "repl~" + strconv.Itoa(int(kind)),
|
||||||
})
|
})
|
||||||
for {
|
for {
|
||||||
|
|||||||
Reference in New Issue
Block a user