Tag: bacon.js

如何分叉/复制一个stream

我有一个外stream。 我想用两种不同的方式使用这个stream。 第一种方法是只听价值观。 第二种方法是用flatMapConcatbuild立一个新的stream。 但我不能同时做两个。 我想我必须叉或复制stream。 我尝试添加一个总线，但它不工作。 var outer = Bacon.fromArray([1, 2, 3, 4, 5]); // 1.way build a new stream var combined = outer.flatMapConcat(function(v) { return Bacon.sequentially(1000, ["a" + v, "b" + v]); }); // 2. way use the plain stream // outer.onValue(function(v) { console.log(v); }); // Tried to insert a bus var forkBus […]

如何接收从socket.io发送的参数使用baconJS发出事件？

我需要一些与socket.io和bacon.JS的帮助： 我在客户端有一个socket.IO发送事件，发送2个参数到服务器，如下所示： $("#btn").asEventStream("click").onValue(function(){ socket.emit("event", param1, param2); }); 然后在服务器端，我需要接收这2个参数，所以我可以做的东西与他们。 按照这个答案的例子，我试着做这样的事情： io.on('connection', function (socket) { socket.on('error', function (err) { console.log(err); }); Bacon.fromEvent(socket, "event", param1, param2) .filter(function(param1, param2){ return true }) .forEach(function(param1, param2){ doStuff(param1, param2); }); }); 但它没有工作。 总结一下，我需要在服务器上以事件stream的forms接收事件，并使用这些参数。 谁能帮我？

无法将socket.io事件转换为Bacon EventStream

在socket.io上的事件绑定下面工作正常， io = require('socket.io')() io.on 'connection', (socket) -> console.log socket.id io.listen 3000 然后尝试将socket.io event转换为Bacon EventStream ， Bacon = require('baconjs').Bacon io = require('socket.io')() connections = Bacon.fromEventTarget io, 'connection' connections.onValue (socket) -> console.log socket.id io.listen 3000 为什么在下面失败？ TypeError: Object connection has no method 'on'