我正在尝试使用 Rx.DOM.fromWebSocket 和 Socket.io 创建一个主题。我真的迷路了——在哪里可以找到 Socket.io 实现的协议(protocol)?
var rxSocket = Rx.DOM.fromWebSocket(
'ws://localhost:12345',
'ws',
function (e) {
console.log('Opening');
});
rxSocket.subscribe(function (next) {
console.log('Received data: ' + next);
});
rxSocket.onNext('data');
这就是我现在所拥有的。我正在尝试在本地连接到运行 Socket.io 的服务器。当我刚刚使用标准的 io.connect()
时,一切运行顺利,因此我的服务器已启动并运行 Socket.io。我试过谷歌,但不知道在哪里可以找到 Socket.io 的套接字协议(protocol)实现。
最佳答案
另一种方法是使用 RxJS Observable.fromEvent。
var socket = io('ws://localhost:8080');
var dataStream = Rx.Observable.fromEvent(socket, 'data');
dataStream.subscribe(function(payload) {
console.log(payload);
});
在此示例中,允许 socket.io 处理连接。
RxJs 处理事件并创建一个 Observable 流来订阅。
关于node.js - RxJS.fromWebSocket 与 Socket.io,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27748974/