Function testPipeToPreventFail

test/parallel/test-stream-iter-pipeto.js:192–207

()

// PipeTo preventFail option
async function testPipeToPreventFail() {
  let failCalled = false;
  const writer = {
    write() {},
    fail() { failCalled = true; },
  };
  // eslint-disable-next-line require-yield
  async function* failingSource() {
    throw new Error('boom');
  }
  await assert.rejects(
    () => pipeTo(failingSource(), writer, { preventFail: true }),
    { message: 'boom' },
  );
  assert.strictEqual(failCalled, false);
}

// PipeToSync preventClose option
async function testPipeToSyncPreventClose() {