diff --git a/pool.js b/pool.js
index 1c5a13a..e1e7207 100644
--- a/pool.js
+++ b/pool.js
@@ -35,7 +35,7 @@ export function relayPool() {
         .map(({relay}) => [
           relay.url,
           relay.sub({cb: event => cb(event, relay.url), filter, beforeSend}, id,
-          cbEose)
+          () => cbEose(relay.url))
         ])
     )
 
@@ -54,7 +54,8 @@ export function relayPool() {
     }) => {
       Object.entries(subControllers).map(([relayURL, sub]) => [
         relayURL,
-        sub.sub({cb: event => cb(event, relayURL), filter, beforeSend}, id)
+        sub.sub({cb: event => cb(event, relayURL), filter, beforeSend}, id,
+          () => cbEose(relayURL))
       ])
       return activeSubscriptions[id]
     }
diff --git a/relay.js b/relay.js
index 251b269..1c3a75e 100644
--- a/relay.js
+++ b/relay.js
@@ -164,7 +164,7 @@ export function relayConnect(url, onNotice = () => {}, onError = () => {}) {
         cb = activeCallback,
         filter = activeFilters,
         beforeSend = activeBeforeSend
-      }) => sub({cb, filter, beforeSend, skipVerification}, channel),
+      }) => sub({cb, filter, beforeSend, skipVerification}, channel, eoseCb),
       unsub: () => {
         delete openSubs[channel]
         delete eventListeners[channel]