Struct rustbus::connection::ll_conn::RecvConn [−][src]
pub struct RecvConn { /* fields omitted */ }Implementations
impl RecvConn[src]
impl RecvConn[src]pub fn can_read_from_source(&self) -> Result<bool>[src]
pub fn bytes_needed_for_current_message(&self) -> Result<usize, Error>[src]
pub fn buffer_contains_whole_message(&self) -> Result<bool, Error>[src]
pub fn read_whole_message(&mut self, timeout: Timeout) -> Result<(), Error>[src]
Blocks until a message has been read from the conn or the timeout has been reached
pub fn read_once(&mut self, timeout: Timeout) -> Result<(), Error>[src]
Blocks until one read towards the message has been performed from the conn or the timeout has been reached
pub fn get_next_message(
&mut self,
timeout: Timeout
) -> Result<MarshalledMessage, Error>[src]
&mut self,
timeout: Timeout
) -> Result<MarshalledMessage, Error>
Blocks until a message has been read from the conn or the timeout has been reached