pub async fn recv(&mut self) -> Result<crate::filters::ws::Message, WsError> {
        self.rx.next().await
            .map(|unbounded_result| {
                unbounded_result.map_err(WsError::new)
            })
            .unwrap_or_else(|| {
                // websocket is closed
                Err(WsError::new("closed"))
            })


    }
/// Receive a websocket message from the server.
Receive a websocket message from the server.
Receive a websocket message from the server .
pub async fn recv(&mut self) -> Result<crate::filters::ws::Message, WsError> {
        self.rx.next().await
            .map(|unbounded_result| {
                unbounded_result.map_err(WsError::new)
            })
            .unwrap_or_else(|| {
                // websocket is closed
                Err(WsError::new("closed"))
            })
    }
pub async fn recv ( & mut self ) -> Result < crate :: filters :: ws :: Message , WsError > { self . rx . next ( ) . await . map ( | unbounded_result | { unbounded_result . map_err ( WsError :: new ) } ) . unwrap_or_else ( | | { // websocket is closed Err ( WsError :: new ( " " ) ) } ) }
Receive a websocket message from the server.
Receive a websocket message from the server .
&mut self