Function testTapSyncErrorPropagation

test/parallel/test-stream-iter-consumers-tap.js:94–100

()

// TapSync callback error propagates through sync pipeline
function testTapSyncErrorPropagation() {
  const badTap = tapSync(() => { throw new Error('tapSync error'); });
  assert.throws(() => {
    // eslint-disable-next-line no-unused-vars
    for (const _ of pullSync(fromSync('hello'), badTap)) { /* consume */ }
  }, { message: 'tapSync error' });
}

// TapSync in a pullSync pipeline passes through data and flush
function testTapSyncInPipeline() {