node.js - RxJS.fromWebSocket 与 Socket.io

Question

我正在尝试使用 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)实现。

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 流来订阅。