Function testTapAsync

test/parallel/test-stream-iter-consumers-tap.js:44–58

()

}

async function testTapAsync() {
  const observed = [];
  const observer = tap(async (chunks) => {
    if (chunks !== null) {
      observed.push(chunks.length);
    }
  });

  assert.strictEqual(typeof observer, 'function');

  const input = [new Uint8Array([1])];
  const result = await observer(input);
  assert.deepStrictEqual(result, input);
  assert.deepStrictEqual(observed, [1]);
}

async function testTapInPipeline() {
  const { writer, readable } = push();