/// Returns a Future that will resolve to the next message
///
/// Returns an error if the client disconnects or if there is an error decoding the message
Returns a Future that will resolve to the next message
Returns an error if the client disconnects or if there is an error decoding the message
Returns a Future that will resolve to the next message Returns an error if the client disconnects or if there is an error decoding the message
pub async fn recv(&mut self) -> Option<Result<BmpMessage, Error>> {
        self.inner.next().await
            .and_then(|m| { self.messages += 1; Some(m) })
            .map(|thing| thing.map_err(|e| e.into()))
    }
pub async fn recv ( & mut self ) -> Option < Result < BmpMessage , Error > > { self . inner . next ( ) . await . and_then ( | m | { self . messages += 1 ; Some ( m ) } ) . map ( | thing | thing . map_err ( | e | e . into ( ) ) ) }
Returns a Future that will resolve to the next message
Returns an error if the client disconnects or if there is an error decoding the message
Returns a Future that will resolve to the next message Returns an error if the client disconnects or if there is an error decoding the message
&mut self