mirror of
https://github.com/nbd-wtf/nostr-tools.git
synced 2025-12-08 16:28:49 +00:00
Added eoseSubTimeout to pool's SubscriptionOptions (#284)
* added timeout sub option * made eoseSubTimeout optional
This commit is contained in:
2
pool.ts
2
pool.ts
@@ -82,7 +82,7 @@ export class SimplePool {
|
|||||||
let eoseTimeout = setTimeout(() => {
|
let eoseTimeout = setTimeout(() => {
|
||||||
eoseSent = true
|
eoseSent = true
|
||||||
for (let cb of eoseListeners.values()) cb()
|
for (let cb of eoseListeners.values()) cb()
|
||||||
}, this.eoseSubTimeout)
|
}, opts?.eoseSubTimeout || this.eoseSubTimeout)
|
||||||
|
|
||||||
relays
|
relays
|
||||||
.filter((r, i, a) => a.indexOf(r) === i)
|
.filter((r, i, a) => a.indexOf(r) === i)
|
||||||
|
|||||||
1
relay.ts
1
relay.ts
@@ -46,6 +46,7 @@ export type SubscriptionOptions = {
|
|||||||
verb?: 'REQ' | 'COUNT'
|
verb?: 'REQ' | 'COUNT'
|
||||||
skipVerification?: boolean
|
skipVerification?: boolean
|
||||||
alreadyHaveEvent?: null | ((id: string, relay: string) => boolean)
|
alreadyHaveEvent?: null | ((id: string, relay: string) => boolean)
|
||||||
|
eoseSubTimeout?: number
|
||||||
}
|
}
|
||||||
|
|
||||||
const newListeners = (): { [TK in keyof RelayEvent]: RelayEvent[TK][] } => ({
|
const newListeners = (): { [TK in keyof RelayEvent]: RelayEvent[TK][] } => ({
|
||||||
|
|||||||
Reference in New Issue
Block a user