所以我试图在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构造函数(提供所有必需的参考)并提供关于我做错了的解释的可行解决方案,那将是非常好的!
最佳答案
调用require
将返回包含WebSocketSubject
的模块,因此您的require调用应如下所示:
const WebSocketSubject = require('rxjs/observable/dom/WebSocketSubject').WebSocketSubject;
或像这样:
const { WebSocketSubject } = require('rxjs/observable/dom/WebSocketSubject');