rxjs5

Question

所以我尝试在 node.js 环境中使用 rxjs 的 Observable.webSocket。我从文档和堆栈溢出 post 中看到，我需要提供自己的 websocket 版本。我遇到的问题是，所提供的两个示例都指示 WebSocketSubject，但它们没有提及它的来源。

const ws = require('nodejs-websocket');
const Rx = require('rxjs/Rx');
const WebSocketSubject = require('rxjs/observable/dom/WebSocketSubject');

socket = new WebSocketSubject({url: 'ws://....', WebSocketCtor: ws.w3cwebsocket});

const marketSocket$ = Rx.Observable.webSocket('ws://....');

这是我检索必要的 WebSocketSubject 的尝试，但我只是收到一个错误，告诉我 "WebSocketSubject is not a constructor"。有什么明显的我想念的东西吗？如果您可以分享一个有效的解决方案，提供一个有效的 websocket 构造函数（提供所有需要的参考资料）以及对我做错了什么的解释，那就太好了！

Answer 1

对 require 的调用将 return 包含 WebSocketSubject 的模块，因此您的 require 调用应如下所示：

const WebSocketSubject = require('rxjs/observable/dom/WebSocketSubject').WebSocketSubject;

或者像这样：

const { WebSocketSubject } = require('rxjs/observable/dom/WebSocketSubject');

rxjs5 - WebSocketSubject 不是构造函数

rxjs5 - WebSocketSubject is not a constructor

javascript

websocket

node.js

rxjs