test.js

  function cycleDriver(outgoing$) {
    console.log('cycleDriver')

    outgoing$.addListener({
      next: outgoing => {
        console.log('outgoing', outgoing)
        // sock.send(outgoing));
      },
      error: () => {},
      complete: () => {},
    });

    return xs.create({
      start: listener => {
        console.log('listener', listener)
        // listener.next(msg);
      },
      stop: () => {},
    });
  }

  drivers.ACTION = cycleDriver;
  run(mainFn, drivers);