Function testChannelClose

test/parallel/test-stream-iter-duplex.js:60–74

()

}

async function testChannelClose() {
  const [channelA, channelB] = duplex();

  await channelA.close();

  // Should be able to close twice without error
  await channelA.close();

  // B's readable should end (A -> B direction is closed)
  const batches = [];
  for await (const batch of channelB.readable) {
    batches.push(batch);
  }
  assert.strictEqual(batches.length, 0);
}

async function testWithOptions() {
  const [channelA, channelB] = duplex({