Trait MessageReceiver

pub trait MessageReceiver<T>
where
    T: Message,
{
    // Provided methods
    fn recv(&self) -> Result<Option<T>, PortError> { ... }
    fn try_recv(&self) -> Result<Option<T>, PortError> { ... }
}

Provided Methods

fn recv(&self) -> Result<Option<T>, PortError>

Receives a message, blocking until one is available.

Returns Ok(Some(message)) if a message was received. Returns Ok(None) if the port is closed or disconnected. Returns Err(PortError) if an error occurs.

fn try_recv(&self) -> Result<Option<T>, PortError>

Tries to receive a message, returning immediately.

Returns Ok(Some(message)) if a message was received. Returns Ok(None) if no message was immediately available. Returns Err(PortError::Disconnected) if the port is disconnected. Returns Err(PortError::Closed) if the port is closed. Returns Err(PortError) if another error occurs.

Implementors

impl<T> MessageReceiver<T> for InputPort<T>

where T: Message,

impl<T, const N: usize> MessageReceiver<T> for InputPorts<T, N>

where T: Message,