RxJS.fromWebSocket与Socket.io

Question

我正在尝试使用带有Socket.io的Rx.DOM.fromWebSocket创建一个Subject.我真的迷路了 - 在哪里可以找到Socket.io实现的协议？

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.我试过谷歌(所以请不要LMGTFY ......)但不知道在哪里可以找到Socket.io的套接字协议实现.

在此先感谢,欢迎所有建议.

最好的问候,安东

Answer 1

另一种方法是使用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流来订阅.