Function testMergeConsumerBreak

test/parallel/test-stream-iter-consumers-merge.js:111–137

()

}

async function testMergeConsumerBreak() {
  let source1Return = false;
  let source2Return = false;
  async function* source1() {
    try {
      while (true) yield [new TextEncoder().encode('a')];
    } finally {
      source1Return = true;
    }
  }

  async function* source2() {
    try {
      while (true) yield [new TextEncoder().encode('b')];
    } finally {
      source2Return = true;
    }
  }
  // eslint-disable-next-line no-unused-vars
  for await (const _ of merge(source1(), source2())) {
    break; // Break after first batch
  }
  // Give async cleanup a tick to complete
  await new Promise(setImmediate);
  // Both sources should be cleaned up
  assert.strictEqual(source1Return && source2Return, true);
}

async function testMergeSignalMidIteration() {
  const ac = new AbortController();