javascript - 在每个新连接上使用 rxjs webSocket 发送消息

Question

使用 rxjs/webSocket ，如何在每个新连接上发送登录消息？似乎最简单的方法是使用 WebSocketSubjectConfig ，挂接到openObserver，从event.target中挖掘出底层的webSocket并发送登录消息。推荐吗？有没有更好的办法？ (使用 Angular ，但我认为这不重要)。

这是我的代码:

ws = webSocket({
    url: "wss://example.com",      
    openObserver: {
      next: (e) => e.target.send("login-info")          
    }
})

Answer 1

您可以使用 webSocket(config).multiplex(() => 'login-info', () => null, () => true) 创建一个多路复用的 WebsocketSubject，它发送一个订阅消息。

此功能最初旨在支持单个 Websocket 上的多个流/主题，但我认为将它用于您的用例也很好。