diff --git a/sdk/addressable_loader.go b/sdk/addressable_loader.go
index 2e922b2..5a5a12a 100644
--- a/sdk/addressable_loader.go
+++ b/sdk/addressable_loader.go
@@ -103,7 +103,7 @@ func (sys *System) batchLoadAddressableEvents(
 	wg.Wait()
 
 	// 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",
 	})
 nextEvent:
diff --git a/sdk/replaceable_loader.go b/sdk/replaceable_loader.go
index b69a984..a49e16a 100644
--- a/sdk/replaceable_loader.go
+++ b/sdk/replaceable_loader.go
@@ -121,7 +121,7 @@ func (sys *System) batchLoadReplaceableEvents(
 
 	// query all relays with the prepared filters
 	wg.Wait()
-	multiSubs := sys.Pool.BatchedSubManyEose(aggregatedContext, relayFilter, nostr.SubscriptionOptions{
+	multiSubs := sys.Pool.BatchedQueryMany(aggregatedContext, relayFilter, nostr.SubscriptionOptions{
 		Label: "repl~" + strconv.Itoa(int(kind)),
 	})
 	for {