Angular项目中的Rxjs websockets

Posted 2023-02-16

【中文标题】Angular项目中的Rxjs websockets

【英文标题】：Rxjs websockets in angular project

【发布时间】：2020-04-08 10:09:59

【问题描述】：

让 observable = Rx.Observable.create((obs: Rx.Observer) =>

  this.ws.onmessage = obs.next.bind(obs);
  this.ws.onerror = obs.error.bind(obs);
  this.ws.onclose = obs.complete.bind(obs);

  return this.ws.close.bind(this.ws);
);

我是 typescript/angular 的新手，在很多关于 websockets 的教程中都看到了这一点，但不明白 完全是怎么回事。从我可以收集到的第一部分是将观察者方法与观察者上下文绑定到 websocket 方法。这对我来说很有意义，但我无法弄清楚回报是什么。 提前谢谢你，如果这看起来有点愚蠢，对不起。

【参考方案1】：

Observable.create 已弃用。为此请使用new Observable。 我不建议您自己创建 WebSocket Observable，因为 RxJS 已经提供了一个。文档可能会更好，但你可以去：https://rxjs.dev/api/webSocket/webSocket 去年在 NgSpain 也有关于这个话题的很好的讨论： https://www.youtube.com/watch?v=BEHDkAFTnzU