Function source

benchmark/streams/iter-throughput-pipeto.js:87–93

()

  async function run() {
    let remaining = datasize;
    async function* source() {
      while (remaining > 0) {
        const size = Math.min(remaining, chunk.length);
        remaining -= size;
        yield [size === chunk.length ? chunk : chunk.subarray(0, size)];
      }
    }
    // Provide writeSync for the sync fast path in pipeTo
    const writer = { write() {}, writeSync() { return true; } };
    await pipeTo(source(), writer);