INNER CODE UNIT · TypeScript

resolveBatchFlush

dmotz/trystero · packages/nostr/src/index.ts:166

const resolveBatchFlush = (batcher: BatchState): void => {
  batcher.flushWaiters.forEach(resolve => resolve())
  batcher.flushWaiters.clear()
}

const batchAdd = (
  client: SocketClient,
  topic: string,
  handler: TopicHandler
): void => {
  const batcher = (batchers[client.url] ??= {
    subIds: [],
    topics: new Map(),
    updateTimer: null,
    flushWaiters: new Set(),
    retryTimer: null,
    retryMs: subscriptionRetryMs,
    pendingEose: new Set(),

View source record →