pub async fn handle_ws_connection( session: Session, stream: MessageStream, tx: Sender<Message>, rx: Receiver<Message>, ) -> Result<()>