fn drain(&mut self) -> Poll<Option<Bytes>, failure::Error> {
        if let Some(record) = self.decoder.decode(&mut self.buf)? {
            Ok(Async::Ready(Some(record)))
        } else {
            Ok(Async::Ready(None))
        }
    }
/// Process all bytes in RecordIoConnection::buf.
Process all bytes in RecordIoConnection::buf.
Process all bytes in RecordIoConnection :: buf .
fn drain(&mut self) -> Poll<Option<Bytes>, failure::Error> {
        if let Some(record) = self.decoder.decode(&mut self.buf)? {
            Ok(Async::Ready(Some(record)))
        } else {
            Ok(Async::Ready(None))
        }
    }
fn drain ( & mut self ) -> Poll < Option < Bytes > , failure :: Error > { if let Some ( record ) = self . decoder . decode ( & mut self . buf ) ? { Ok ( Async :: Ready ( Some ( record ) ) ) } else { Ok ( Async :: Ready ( None ) ) } }
Process all bytes in RecordIoConnection::buf.
Process all bytes in RecordIoConnection :: buf .
&mut self
&mut self