pub fn poll_inbound_read(
        &mut self,
        cx: &mut Context<'_>,
        ) -> Result<Option<Frame>>
    {
        let msg = self.read_state.poll_reader(cx, &mut self.io);
        return match msg {
            Poll::Ready(Ok(message)) => Ok(Some(message)),
            Poll::Ready(Err(e)) => Err(anyhow!(e)),
            Poll::Pending => Ok(None),
        }
    }
/// Poll for inbound messages and process them.
Poll for inbound messages and process them.
Poll for inbound messages and process them .
pub fn poll_inbound_read(
        &mut self,
        cx: &mut Context<'_>,
        ) -> Result<Option<Frame>>
    {
        let msg = self.read_state.poll_reader(cx, &mut self.io);
        return match msg {
            Poll::Ready(Ok(message)) => Ok(Some(message)),
            Poll::Ready(Err(e)) => Err(anyhow!(e)),
            Poll::Pending => Ok(None),
        }
    }
pub fn poll_inbound_read ( & mut self , cx : & mut Context < ' _ > , ) -> Result < Option < Frame > > { let msg = self . read_state . poll_reader ( cx , & mut self . io ) ; return match msg { Poll :: Ready ( Ok ( message ) ) => Ok ( Some ( message ) ) , Poll :: Ready ( Err ( e ) ) => Err ( anyhow ! ( e ) ) , Poll :: Pending => Ok ( None ) , } }
Poll for inbound messages and process them.
Poll for inbound messages and process them .
&mut self
cx
&mut Context<'_>
&mut self
cx
&mut Context<'_>