Function testMergeWithAbortSignal

test/parallel/test-stream-iter-consumers-merge.js:57–69

()

}

async function testMergeWithAbortSignal() {
  const merged = merge(from('data'), { signal: AbortSignal.abort() });

  await assert.rejects(
    async () => {
      // eslint-disable-next-line no-unused-vars
      for await (const _ of merged) {
        assert.fail('Should not reach here');
      }
    },
    { name: 'AbortError' },
  );
}

// Regression test: merge() with sync iterable sources
async function testMergeSyncSources() {