Struct ProcessReceiver 

pub struct ProcessReceiver<T: Receivable> { /* private fields */ }

Used to receive messages from processes.

Implementations

impl<T> ProcessReceiver<T>

where T: Receivable,

pub fn strict_type_checking(self) -> Self

Enables strict type checking which will panic if the message type doesn’t match.

pub fn for_message<N: Receivable>(self) -> ProcessReceiver<N>

Sets the message type this receiver will handle.

pub async fn select<F: Fn(&Message<&T>) -> bool + Send>( self, filter: F, ) -> Message<T>

Selects a single message.

pub fn remove<F: FnMut(&Message<&T>) -> bool + Send>(self, filter: F)

Removes any message that is already in the message queue matching the filter.

pub async fn receive(self) -> Message<T>

Receives a single message.