Function testMergeCleanupErrorOnly

test/parallel/test-stream-iter-consumers-merge.js:199–221

()

// Cleanup error with no primary error: iterator.return() throws during
// normal completion. The cleanup error should propagate directly.
async function testMergeCleanupErrorOnly() {
  async function* source() {
    yield [new TextEncoder().encode('data')];
  }

  async function* failingReturnSource() {
    try {
      yield [new TextEncoder().encode('more')];
    } finally {
      throwInFinally('cleanup boom');
    }
  }

  await assert.rejects(
    async () => {
      // eslint-disable-next-line no-unused-vars
      for await (const _ of merge(source(), failingReturnSource())) {
        // Consume all - no primary error
      }
    },
    { message: 'cleanup boom' },
  );
}

// Primary error + cleanup error: a source throws during iteration AND
// iterator.return() also throws. Should get a SuppressedError.