rxjs5 - WebSocketSubject 不是构造函数

Question

所以我尝试在 node.js 环境中使用 rxjs 的 Observable.webSocket。我从文档和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 的模块，因此您的require 调用应如下所示：

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

或者像这样：

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