Function testBackpressureAsync

test/parallel/test-stream-iter-to-readable.js:67–86

()

// =============================================================================

async function testBackpressureAsync() {
  let batchCount = 0;
  async function* gen() {
    for (let i = 0; i < 10; i++) {
      batchCount++;
      yield [Buffer.from(`chunk${i}`)];
    }
  }

  const readable = toReadable(gen(), { highWaterMark: 1 });

  // Read one chunk at a time with delays to exercise backpressure
  const chunks = [];
  for await (const chunk of readable) {
    chunks.push(chunk);
  }

  assert.strictEqual(chunks.length, 10);
  assert.strictEqual(batchCount, 10);
}

// =============================================================================
// fromStreamIter: source error mid-stream