import {RxServer, RxClient} from "rx-messaging";
 
let server = new RxServer()
server.channel("my-channel").messages$
  .subscribe(msg => {
    console.log(msg.data);
    server.close();
  });
server.listen(12345);
 
let client = new RxClient({port: 12345});
client.connect();
client.send("my-channel", {foo: "bar"});
  .then(() => client.disconnect());