Rx Subject for Node sockets
npm install rx-socket``sh`
yarn add rx-socket
`js
import { 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.