Function testWithOptions

test/parallel/test-stream-iter-duplex.js:76–87

()

}

async function testWithOptions() {
  const [channelA, channelB] = duplex({
    highWaterMark: 2,
    backpressure: 'strict',
  });

  await channelA.writer.write('msg');
  await channelA.close();

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

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