Function testBackpressureSync

test/parallel/test-stream-iter-to-readable.js:423–438

()

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

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

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

  const chunks = [];
  for await (const chunk of readable) {
    chunks.push(chunk);
  }

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

// =============================================================================
// fromStreamIterSync: backpressure within a batch