Function testMultipleWrites

test/parallel/test-stream-iter-duplex.js:48–58

()

}

async function testMultipleWrites() {
  const [channelA, channelB] = duplex({ highWaterMark: 10 });

  await channelA.writer.write('one');
  await channelA.writer.write('two');
  await channelA.writer.write('three');
  await channelA.close();

  const data = await text(channelB.readable);
  assert.strictEqual(data, 'onetwothree');
}

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