Function testMergeSourceError

test/parallel/test-stream-iter-consumers-merge.js:87–109

()

// =============================================================================

async function testMergeSourceError() {
  async function* goodSource() {
    const enc = new TextEncoder();
    yield [enc.encode('a')];
    // Slow so the bad source errors first
    await new Promise((r) => setTimeout(r, 50));
    yield [enc.encode('b')];
  }

  async function* badSource() {
    yield [new TextEncoder().encode('x')];
    throw new Error('merge source boom');
  }
  await assert.rejects(
    async () => {
      // eslint-disable-next-line no-unused-vars
      for await (const _ of merge(goodSource(), badSource())) {
        /* consume */
      }
    },
    { message: 'merge source boom' },
  );
}

async function testMergeConsumerBreak() {
  let source1Return = false;