Function testLargeDataAsync

test/parallel/test-stream-iter-to-readable.js:210–228

()

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

async function testLargeDataAsync() {
  const totalSize = 1024 * 1024;  // 1 MB
  const chunkSize = 16384;

  async function* gen() {
    let remaining = totalSize;
    while (remaining > 0) {
      const size = Math.min(chunkSize, remaining);
      yield [Buffer.alloc(size, 0x42)];  // Fill with 'B'
      remaining -= size;
    }
  }

  const readable = toReadable(gen());
  const result = await collect(readable);
  assert.strictEqual(result.length, totalSize);
  assert.strictEqual(result[0], 0x42);
  assert.strictEqual(result[totalSize - 1], 0x42);
}

// =============================================================================
// fromStreamIter: pipe to Writable