pub fn poll_outbound_write(&mut self, cx: &mut Context<'_>) -> Result<()>
    {
        let poll = self.write_state.poll_send(cx, &mut self.io);
        if let Poll::Ready(Err(e)) = poll {
            return Err(anyhow!(e));
        }
        return Ok(());
    }
/// Poll for outbound messages and write them.
Poll for outbound messages and write them.
Poll for outbound messages and write them .
pub fn poll_outbound_write(&mut self, cx: &mut Context<'_>) -> Result<()>
    {
        let poll = self.write_state.poll_send(cx, &mut self.io);
        if let Poll::Ready(Err(e)) = poll {
            return Err(anyhow!(e));
        }
        return Ok(());
    }
pub fn poll_outbound_write ( & mut self , cx : & mut Context < ' _ > ) -> Result < ( ) > { let poll = self . write_state . poll_send ( cx , & mut self . io ) ; if let Poll :: Ready ( Err ( e ) ) = poll { return Err ( anyhow ! ( e ) ) ; } return Ok ( ( ) ) ; }
Poll for outbound messages and write them.
Poll for outbound messages and write them .
&mut self
cx
&mut Context<'_>
&mut self
cx
&mut Context<'_>