Function testPipeToSyncWithTransforms

test/parallel/test-stream-iter-pipeto.js:126–142

()

// PipeToSync with transforms
async function testPipeToSyncWithTransforms() {
  const chunks = [];
  const writer = {
    writeSync(chunk) { chunks.push(new TextDecoder().decode(chunk)); return true; },
  };
  const upper = (batch) => {
    if (batch === null) return null;
    return batch.map((c) => {
      const out = new Uint8Array(c);
      for (let i = 0; i < out.length; i++)
        out[i] -= (out[i] >= 97 && out[i] <= 122) * 32;
      return out;
    });
  };
  pipeToSync(fromSync('hello'), upper, writer);
  assert.strictEqual(chunks.join(''), 'HELLO');
}

async function testPipeToWriterTransformMethodIgnored() {
  const chunks = [];