RxJS5 WebSocketSubject和socket.io

Question

有没有人可以指引我在RxJS中使用socket.io的正确方向？我一直在试验我自己的实现，但我想知道是否有首选的标准。

我看过rxjs5的WebSocketSubject，有没有类似socket.io的东西？

提前感谢

Answer 1

我在我的应用程序中所做的是使用fromEventPattern包装一个事件表单socket io。这样，您就可以获得传递给套接字的每个事件的可观察值。我想，实际上没有必要为您创建一个单独的库来做这件事。

Rx.Observable.fromEventPattern(
   function add (h) {
     socket.on('whatever event you are throwing',h);
   }
);