Function testWithTransformAsync

test/parallel/test-stream-iter-to-readable.js:372–389

()

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

async function testWithTransformAsync() {
  // Uppercase transform
  function upper(chunks) {
    if (chunks === null) return null;
    return chunks.map((c) => {
      const buf = Buffer.from(c);
      for (let i = 0; i < buf.length; i++) {
        if (buf[i] >= 97 && buf[i] <= 122) buf[i] -= 32;
      }
      return buf;
    });
  }

  const source = pull(from('hello world'), upper);
  const readable = toReadable(source);
  const result = await collect(readable);
  assert.strictEqual(result.toString(), 'HELLO WORLD');
}

// =============================================================================
// fromStreamIterSync: basic sync round-trip