Function writeAsyncIterableToWritable

packages/react-router-node/stream.ts:132–174

(
  iterable: AsyncIterable<Uint8Array>,
  writable: Writable,
)

}

export async function writeAsyncIterableToWritable(
  iterable: AsyncIterable<Uint8Array>,
  writable: Writable,
) {
  let writableError = monitorWritableError(writable);
  let iterator = iterable[Symbol.asyncIterator]();
  let completed = false;

  try {
    while (true) {
      writableError.throwIfClosed();

      let { done, value: chunk } = await writableError.race(iterator.next());

      if (done) {
        completed = true;
        break;
      }

      writableError.throwIfClosed();

      let canContinueWriting = writable.write(chunk);

      if (!canContinueWriting) {
        await waitForDrain(writable, writableError);
      }
    }

    writable.end();
  } catch (error: any) {
    if (!completed) {
      try {
        Promise.resolve(iterator.return?.()).catch(() => {});
      } catch {
        // Ignore return errors so we preserve the original write failure.
      }
    }
    writable.destroy(error);
    throw error;
  } finally {
    writableError.cleanup();
  }
}

export async function readableStreamToString(
  stream: ReadableStream<Uint8Array>,