Update pool.js

This commit is contained in:
monlovesmango
2022-06-22 15:18:49 -05:00
committed by fiatjaf
parent ed52d2a8d4
commit 536dbcbffe

View File

@@ -53,12 +53,12 @@ export function relayPool() {
}) => { }) => {
Object.entries(subControllers).map(([relayURL, sub]) => [ Object.entries(subControllers).map(([relayURL, sub]) => [
relayURL, relayURL,
sub.sub({cb: event => cb(event, relayURL), filter, beforeSend}, id) sub.sub({ cb: event => cb(event, relayURL), filter, beforeSend }, id)
]) ])
return activeSubscriptions[id] return activeSubscriptions[id]
} }
const addRelay = relay => { const addRelay = relay => {
subControllers[relay.url] = relay.sub({cb: event => cb(event, relay.url), filter}, id) subControllers[relay.url] = relay.sub({ cb: event => cb(event, relay.url), filter, beforeSend }, id)
return activeSubscriptions[id] return activeSubscriptions[id]
} }
const removeRelay = relayURL => { const removeRelay = relayURL => {