diff --git a/pool.ts b/pool.ts index 7076360..bda36bb 100644 --- a/pool.ts +++ b/pool.ts @@ -82,7 +82,7 @@ export class SimplePool { let eoseTimeout = setTimeout(() => { eoseSent = true for (let cb of eoseListeners.values()) cb() - }, this.eoseSubTimeout) + }, opts?.eoseSubTimeout || this.eoseSubTimeout) relays .filter((r, i, a) => a.indexOf(r) === i) diff --git a/relay.ts b/relay.ts index 1c160c7..e4caa8e 100644 --- a/relay.ts +++ b/relay.ts @@ -46,6 +46,7 @@ export type SubscriptionOptions = { verb?: 'REQ' | 'COUNT' skipVerification?: boolean alreadyHaveEvent?: null | ((id: string, relay: string) => boolean) + eoseSubTimeout?: number } const newListeners = (): { [TK in keyof RelayEvent]: RelayEvent[TK][] } => ({