Function failingSource

test/parallel/test-stream-iter-pipeto.js:57–60

()

    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' },