Function testPipeAsync

test/parallel/test-stream-iter-to-readable.js:234–253

()

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

async function testPipeAsync() {
  const source = from('pipe test data');
  const readable = toReadable(source);

  const chunks = [];
  const writable = new Writable({
    write(chunk, enc, cb) {
      chunks.push(chunk);
      cb();
    },
  });

  await new Promise((resolve, reject) => {
    readable.pipe(writable);
    writable.on('finish', resolve);
    writable.on('error', reject);
  });

  assert.strictEqual(Buffer.concat(chunks).toString(), 'pipe test data');
}

// =============================================================================
// fromStreamIter: not object mode