我想在我的中使用RxJS socket.on('sense',function(data){});。我被很少的可用文档和缺乏对RxJS的理解所困扰和困惑。这是我的问题。
我有一个distSensor.js具有功能pingEnd（）
function pingEnd(x){
socket.emit("sense", dist); //pingEnd is fired when an Interrupt is generated.
}
在我的App.js中，
io.on('connection', function (socket) {
socket.on('sense', function (data) {
//console.log('sense from App4 was called ' + data);
});
});
传感函数获取大量传感器数据，我想使用RxJS进行过滤，我不知道接下来在这里使用RxJ时应该做什么。任何指向正确文档或示例的指针都将有所帮助。
您可以使用Rx.Observable.fromEvent（https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/fromevent.md）。
这是我使用Bacon.js做类似的事情的方法，Bacon.js具有非常相似的API：https：//github.com/raimohanska/bacon-minsk-2015/blob/gh-pages/server.js#L13
所以在Bacon.js中，它会像
io.on('connection', function(socket){
Bacon.fromEvent(socket, "sense")
.filter(function(data) { return true })
.forEach(function(data) { dealWith(data) })
})
在RxJ中，您将替换Bacon.fromEvent为Rx.Observable.fromEvent。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句