Function testEmptyDuplex

test/parallel/test-stream-iter-duplex.js:130–142

()

}

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

  // Close without writing
  await channelA.close();
  await channelB.close();

  const dataAtA = await bytes(channelA.readable);
  const dataAtB = await bytes(channelB.readable);

  assert.strictEqual(dataAtA.byteLength, 0);
  assert.strictEqual(dataAtB.byteLength, 0);
}

// Channel fail propagation
async function testChannelFail() {