rxjs5 - WebSocketSubject不是构造函数。

Question

因此，我试图在Observable.webSocket环境中使用rxjs的node.js。我从docs和this堆栈溢出帖子中看到，我需要提供自己版本的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不是构造函数“。我错过了什么痛苦而明显的东西吗？如果您可以共享一个工作解决方案，提供一个有效的websocket构造函数(提供了所有所需的引用)，并解释我做错了什么，那就太好了！

Answer 1

对require的调用将返回包含WebSocketSubject的模块，因此您的需求调用应该如下所示：

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

或者像这样：

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