Function testPipeTo

test/parallel/test-stream-iter-pipeto.js:24–35

()

}

async function testPipeTo() {
  const written = [];
  const writer = {
    async write(chunk) { written.push(chunk); },
    async end() { return written.length; },
    async fail() {},
  };

  const totalBytes = await pipeTo(from('async-pipe-data'), writer);
  assert.strictEqual(totalBytes, 15); // 'async-pipe-data' = 15 UTF-8 bytes
  assert.ok(written.length > 0);
}

async function testPipeToPreventClose() {
  let endCalled = false;