nostr/coracle
1
0
Fork 0
mirror of https://github.com/coracle-social/coracle.git synced 2024-09-19 19:46:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Wait only for one eose

Browse Source
This commit is contained in:
Jonathan Staab 2022-12-17 14:20:29 -08:00
parent 302cbf557f
commit d23742d33e
1 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/relay/pool.js
View File

@ -36,16 +36,10 @@ class Channel {
// before they can get a new one.
await p
// Start our subscription, wait for all relays to eose before
// calling it done
const eoseRelays = []
const sub = pool.sub({filter, cb: onEvent}, this.name, r => {
eoseRelays.push(r)
if (eoseRelays.length === Object.keys(pool.relays).length) {
onEose()
}
})
// Start our subscription, wait for only one relays to eose before
// calling it done. We were waiting for all before, but that made
// the slowest relay a bottleneck
const sub = pool.sub({filter, cb: onEvent}, this.name, onEose)
return {
unsub: () => {