Function baseChannelTest

test/channel.test.js:15–35

(client, server)

const LOG_ERRORS = process.env.LOG_ERRORS;

function baseChannelTest(client, server) {
  return (_t, done) => {
    const decrementLatch = latch(2, done);
    const pair = util.socketPair();
    const c = new Connection(pair.client);

    if (LOG_ERRORS) c.on('error', console.warn);

    c.open(OPEN_OPTS, (err, _ok) => {
      if (err === null) client(c, decrementLatch);
      else decrementLatch(err);
    });

    pair.server.read(8); // discard the protocol header
    util.runServer(pair.server, (send, wait) => {
      handshake(send, wait).then(() => {
        server(send, wait, decrementLatch);
      }, decrementLatch);
    });
  };
}

function channelTest(client, server) {
  return baseChannelTest(