rx-messaging A lightweight tcp/tls messaging protocol implementation based on rxjs. Example 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());