Function waitForDrain

packages/react-router-node/stream.ts:111–130

(
  writable: Writable,
  writableError: WritableErrorMonitor,
)

}

function waitForDrain(
  writable: Writable,
  writableError: WritableErrorMonitor,
): Promise<void> {
  let cleanup = () => {};
  let drainPromise = new Promise<void>((resolve) => {
    function onDrain() {
      cleanup();
      resolve();
    }

    cleanup = function cleanup() {
      writable.off("drain", onDrain);
    };

    writable.once("drain", onDrain);
  });

  return writableError.race(drainPromise).finally(cleanup);
}

export async function writeAsyncIterableToWritable(
  iterable: AsyncIterable<Uint8Array>,