Function testMultiBatchAsync

test/parallel/test-stream-iter-to-readable.js:46–61

()

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

async function testMultiBatchAsync() {
  async function* gen() {
    for (let i = 0; i < 5; i++) {
      const batch = [];
      for (let j = 0; j < 3; j++) {
        batch.push(Buffer.from(`${i}-${j} `));
      }
      yield batch;
    }
  }

  const readable = toReadable(gen());
  const result = await collect(readable);
  assert.strictEqual(result.toString(),
                     '0-0 0-1 0-2 1-0 1-1 1-2 2-0 2-1 2-2 3-0 3-1 3-2 4-0 4-1 4-2 ');
}

// =============================================================================
// fromStreamIter: backpressure with small highWaterMark