Trait protoflow_core::MessageReceiver

source ·

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

Provided Methods§

source

fn recv(&self) -> PortResult<Option<T>>

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.

source

fn try_recv(&self) -> PortResult<Option<T>>

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§

source §

impl<T: Message> MessageReceiver<T> for InputPort<T>