Function getData

cli/unstable_progress_bar_stream_test.ts:6–15

(
  loops: number,
  bufferSize: number,
  delay = 5,
)

import { ProgressBarStream } from "./unstable_progress_bar_stream.ts";

async function* getData(
  loops: number,
  bufferSize: number,
  delay = 5,
): AsyncGenerator<Uint8Array> {
  for (let i = 0; i < loops; ++i) {
    yield new Uint8Array(bufferSize);
    await new Promise((a) => setTimeout(a, delay));
  }
}

Deno.test("ProgressBarStream() flushes", async () => {
  const { readable, writable } = new TransformStream();