Function testPipeToSourceError

test/parallel/test-stream-iter-pipeto.js:50–67

()

// PipeTo source error calls writer.fail()
async function testPipeToSourceError() {
  let failCalled = false;
  let failReason;
  const writer = {
    write() {},
    fail(reason) { failCalled = true; failReason = reason; },
  };
  async function* failingSource() {
    yield [new TextEncoder().encode('a')];
    throw new Error('pipe source boom');
  }
  await assert.rejects(
    () => pipeTo(failingSource(), writer),
    { message: 'pipe source boom' },
  );
  assert.strictEqual(failCalled, true);
  assert.strictEqual(failReason.message, 'pipe source boom');
}

// PipeToSync source error calls writer.fail()
async function testPipeToSyncSourceError() {