INNER CODE UNIT · TypeScript

waitForBatchFlush

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

const waitForBatchFlush = (client: SocketClient): Promise<void> => {
  const batcher = batchers[client.url]

  if (!batcher || batcher.updateTimer === null) {
    return Promise.resolve()
  }

  return new Promise(resolve => batcher.flushWaiters.add(resolve))
}

const flushBatch = (client: SocketClient): void => {
  const batcher = batchers[client.url]

  if (!batcher || batcher.topics.size === 0) {
    return
  }

  const topics = [...batcher.topics.keys()]

View source record →