Function source

test/parallel/test-stream-iter-share-async.js:139–142

()

  const reason = new Error('share aborted');
  const enc = new TextEncoder();
  async function* source() {
    yield [enc.encode('a')];
    yield [enc.encode('b')];
  }
  const shared = share(source(), {
    highWaterMark: 1,
    backpressure: 'block',