pub fn recv_message(&mut self) -> Option<MessageReader> {
        let mut buf = self.take_recv_message()?;
        let reader = GrpcByteBufferReader::from(&mut buf);
        let length = reader.len();

        Some(MessageReader {
            _buf: buf,
            reader,
            buffer_slice: Default::default(),
            buffer_offset: 0,
            buffer_len: 0,
            length,
        })
    }
/// Fetch the response bytes of the rpc call.
Fetch the response bytes of the rpc call.
Fetch the response bytes of the rpc call .
pub fn recv_message(&mut self) -> Option<MessageReader> {
        let mut buf = self.take_recv_message()?;
        let reader = GrpcByteBufferReader::from(&mut buf);
        let length = reader.len();
        Some(MessageReader {
            _buf: buf,
            reader,
            buffer_slice: Default::default(),
            buffer_offset: 0,
            buffer_len: 0,
            length,
        })
    }
pub fn recv_message ( & mut self ) -> Option < MessageReader > { let mut buf = self . take_recv_message ( ) ? ; let reader = GrpcByteBufferReader :: from ( & mut buf ) ; let length = reader . len ( ) ; Some ( MessageReader { _buf : buf , reader , buffer_slice : Default :: default ( ) , buffer_offset : 0 , buffer_len : 0 , length , } ) }
Fetch the response bytes of the rpc call.
Fetch the response bytes of the rpc call .
&mut self
&mut self