所以我试图在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');

08-26 22:38