Function testPipeToWithTransforms

test/parallel/test-stream-iter-pipeto.js:107–123

()

// PipeTo with transforms
async function testPipeToWithTransforms() {
  const chunks = [];
  const writer = {
    write(chunk) { chunks.push(new TextDecoder().decode(chunk)); },
  };
  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;
    });
  };
  await pipeTo(from('hello'), upper, writer);
  assert.strictEqual(chunks.join(''), 'HELLO');
}

// PipeToSync with transforms
async function testPipeToSyncWithTransforms() {