pub fn poll_flush(&mut self) -> Poll<(), io::Error> {
        while !self.wr.is_empty() {
            // Try to write to the socket.
            let n = try_ready!(self.socket.poll_write(&self.wr));

            // Discard the bytes that were just written.
            let _ = self.wr.split_to(n);
        }
        Ok(Async::Ready(()))
    }
/// Flush the write buffer to the socket.
///
/// This will write any buffered data to the socket as it's
/// available and clear it from the write buffer afterwards.
Flush the write buffer to the socket.
This will write any buffered data to the socket as it's
available and clear it from the write buffer afterwards.
Flush the write buffer to the socket . This will write any buffered data to the socket as it ' s available and clear it from the write buffer afterwards .
pub fn poll_flush(&mut self) -> Poll<(), io::Error> {
        while !self.wr.is_empty() {
            // Try to write to the socket.
            let n = try_ready!(self.socket.poll_write(&self.wr));
            // Discard the bytes that were just written.
            let _ = self.wr.split_to(n);
        }
        Ok(Async::Ready(()))
    }
pub fn poll_flush ( & mut self ) -> Poll < ( ) , io :: Error > { while ! self . wr . is_empty ( ) { // Try to write to the socket. let n = try_ready ! ( self socket poll_write ( self wr ) ) ; // Discard the bytes that were just written. let _ = self . wr . split_to ( n ) ; } Ok ( Async :: Ready ( ( ) ) ) }
Flush the write buffer to the socket.
Flush the write buffer to the socket .
&mut self
&mut self