rx-messaging
v0.1.1
Published
A channeled messaging protocol implementation on top of TCP/TLS server and socket to enable rxjs messaging
Downloads
2
Maintainers
Readme
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());