Function testPipeToSyncSourceError

test/parallel/test-stream-iter-pipeto.js:70–85

()

// PipeToSync source error calls writer.fail()
async function testPipeToSyncSourceError() {
  let failCalled = false;
  const writer = {
    writeSync() { return true; },
    fail(reason) { failCalled = true; },
  };
  function* failingSource() {
    yield [new TextEncoder().encode('a')];
    throw new Error('sync pipe boom');
  }
  assert.throws(
    () => pipeToSync(failingSource(), writer),
    { message: 'sync pipe boom' },
  );
  assert.strictEqual(failCalled, true);
}

// PipeTo with AbortSignal
async function testPipeToWithSignal() {