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>) -> Self

pub fn new<R>(inbox: R) -> Self

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

Trait Implementations

impl<T> Clone for DynInbox<T>

fn clone(&self) -> Self

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, ) -> BoxFuture<'_, Result<(), SendCheckedError<BoxedPayload>>>

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: Members> PolyBox for DynInbox<T>

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<Kind: MessageSpecifier<T, Output: Send, Payload: Send>>, R: Members + Contains<T>,

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

Sends a message of type T to the inbox.

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

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