rx-ws-wrapper v1.0.2

ws-rx-end

use websocket and rx to define a quick end

quick usage

• new usage with middleware wrapper

// init express app
const app = express()
// wrap the app with wrapper
const wrapper = new WsRxWrapper(app, {})

// use app as normal app
app.get('/', (req, res, next) => {
	res.sendStatus(200);
})

app.listen(4000)

// if you want to push stream to client with path
const publishTo = wrapper.publishOperator()
rx.interval(1000).pipe(
	publishTo('/interval')
)
.subscribe();