Function testTapSync

test/parallel/test-stream-iter-consumers-tap.js:22–42

()

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

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

  // tapSync returns a function transform
  assert.strictEqual(typeof observer, 'function');

  // Test that it passes data through unchanged
  const input = [new Uint8Array([1]), new Uint8Array([2])];
  const result = observer(input);
  assert.deepStrictEqual(result, input);
  assert.deepStrictEqual(observed, [2]);

  // null (flush) passes through
  const flushResult = observer(null);
  assert.strictEqual(flushResult, null);
}

async function testTapAsync() {
  const observed = [];