Struct DynInbox 

pub struct DynInbox<T> { /* private fields */ }

A dynamic inbox that can accept messages of any type, as long as they are part of the specified set.

An inbox is typed as: DynInbox<Set![Msg1, Msg2, ...]>.

Conversions between inboxes:

• Into more specific subsets -> PolyboxExt::into_dyn_subset.
• Into more general supersets -> PolyboxExt::into_dyn_checked or PolyBox::into_dyn_unchecked.

Implementations

impl<T> DynInbox<T>

pub fn new_unchecked(inbox: Arc<dyn DynPolyBox>) -> DynInbox<T>

pub fn new<R>(inbox: R) -> DynInbox<T>

where R: DynPolyBox + PolyBox + 'static, T: SubsetOf<<R as PolyBox>::Set>,

Trait Implementations

impl<T> Clone for DynInbox<T>

fn clone(&self) -> DynInbox<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> DynPolyBox for DynInbox<T>

fn _send_boxed_payload_checked( &self, msg: BoxedPayload, ) -> Pin<Box<dyn Future<Output = Result<(), SendCheckedError<BoxedPayload>>> + Send + '_>>

Send a boxed payload.

fn _send_boxed_payload_checked_blocking( &self, msg: BoxedPayload, ) -> Result<(), SendCheckedError<BoxedPayload>>

Same as Self::_send_boxed_payload_checked, but blocks the current thread until the message is sent.

impl<T> PolyBox for DynInbox<T>

where T: Members,

type Set = T

The set of message types that this inbox can accept.

fn into_dyn_unchecked<R>(self) -> DynInbox<R>

Converts into a dynamic inbox without checking if the types are compatible.

impl<T, R> Sends<T> for DynInbox<R>

where T: Message, <T as Message>::Kind: MessageSpecifier<T>, <<T as Message>::Kind as MessageSpecifier<T>>::Output: Send, <<T as Message>::Kind as MessageSpecifier<T>>::Payload: Send, R: Members + Contains<T>,

async fn send( &self, msg: T, ) -> Result<<<T as Message>::Kind as MessageSpecifier<T>>::Output, SendError<T>>

Sends a message of type T to the inbox.

fn send_blocking( &self, msg: T, ) -> Result<<<T as Message>::Kind as MessageSpecifier<T>>::Output, SendError<T>>

Same as Sends::send, but blocks the current thread until the message is sent.