Function testTapAsyncErrorPropagation

test/parallel/test-stream-iter-consumers-tap.js:85–91

()

// Tap callback error propagates through async pipeline
async function testTapAsyncErrorPropagation() {
  const badTap = tap(() => { throw new Error('tap error'); });
  await assert.rejects(async () => {
    // eslint-disable-next-line no-unused-vars
    for await (const _ of pull(from('hello'), badTap)) { /* consume */ }
  }, { message: 'tap error' });
}

// TapSync callback error propagates through sync pipeline
function testTapSyncErrorPropagation() {