Function testPipeToSync

test/parallel/test-stream-iter-pipeto.js:8–22

()

const { pipeTo, pipeToSync, from, fromSync } = require('stream/iter');

async function testPipeToSync() {
  const written = [];
  const writer = {
    writeSync(chunk) { written.push(chunk); return true; },
    endSync() { return written.length; },
    fail() {},
  };

  const totalBytes = pipeToSync(fromSync('pipe-data'), writer);
  assert.strictEqual(totalBytes, 9); // 'pipe-data' = 9 UTF-8 bytes
  assert.ok(written.length > 0);
  const result = new TextDecoder().decode(
    new Uint8Array(written.reduce((acc, c) => [...acc, ...c], [])));
  assert.strictEqual(result, 'pipe-data');
}

async function testPipeTo() {
  const written = [];