RxJS Subject for Node Socket.
yarn add rx-socketimport { SocketSubject } from 'rx-socket'
const socket = new SocketSubject('/path/to/socket')
socket.subscribe(data => {
// `data` will be an Object, expecting a JSON-encoded string to be provided
console.log(data)
})
// `next()` will encode the provided value to JSON
socket.next({ hello: 'world' })See the
socket.connect() documentation
for the supported SocketSubject constructor argument.
MIT.
See LICENSE file.