Examples of using for-await-of syntax to consume streams.

asyncIterable-stream-forAwaitOf-examples.ts

export const batchStream = (size: number) =>
  async function* batchStream<TStreamType>(stream: AsyncIterable<TStreamType>) {
    let buffer: TStreamType[] = [];
    for await (const chunk of stream) {
      buffer.push(chunk);
      if (buffer.length >= size) {
        yield buffer;
        buffer = [];
      }
    }
    if (buffer.length > 0) yield buffer;
    buffer = [];
  };