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

Question

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

这是我的代码：

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 上的多个流/主题，但我认为也可以将其用于您的用例。