小编mac*_*oft的帖子

const ws = Observable.webSocket('ws://…');
ws.subscribe(
  message => console.log(message),
  error => console.log(error),
  () => {},
);

我想观察我与 RxJS 的 WebSocket 连接。onmessage通过订阅 observable来对事件做出反应就像一种魅力。但是如何访问onopenWebSocket的事件呢？是否可以触发 WebSocket.close()方法？RxJS 对我来说很新，我研究了几个小时，但也许我只是不知道正确的术语。提前致谢。