Struct meio::prelude::Address

pub struct Address<A: Actor> { /* fields omitted */ }

Address to send messages to Actor.

Can be compared each other to identify senders to the same Actor.

Implementations

impl<A: Actor> Address<A>

pub fn id(&self) -> IdOf<A>

Returns a typed id of the Actor.

pub async fn act<I>(&mut self, input: I) -> Result<(), Error> where
    I: Action,
    A: ActionHandler<I>, 

Just sends an Action to the Actor.

pub fn instant<I>(&mut self, input: I) -> Result<(), Error> where
    I: InstantAction,
    A: InstantActionHandler<I>, 

Just sends an Action to the Actor.

pub fn schedule<I>(&mut self, input: I, deadline: Instant) -> Result<(), Error> where
    I: Send + 'static,
    A: Scheduled<I>, 

Just sends an Action to the Actor.

pub async fn interact<I>(&mut self, request: I) -> Result<I::Output, Error> where
    I: Interaction,
    A: InteractionHandler<I>, 

Interacts with an Actor and waits for the result of the Interaction.

pub async fn join(&mut self)

Waits when the Actor will be terminated.

pub fn attach<S>(&self, stream: S) where
    A: Consumer<S::Item>,
    S: Stream + Send + Unpin + 'static,
    S::Item: Send + 'static, 

Attaches a Stream of event to an Actor.

pub fn link<T>(&self) -> T where
    T: From<Self>, 

Returns a Link to an Actor. Link is a convenient concept for creating wrappers for Address that provides methods instead of using message types directly. It allows also to use private message types opaquely.

pub fn action_recipient<T>(&self) -> Box<dyn ActionRecipient<T>> where
    T: Action,
    A: ActionHandler<T>, 

Returns an ActionRecipient instance.

pub fn interaction_recipient<T>(&self) -> Box<dyn InteractionRecipient<T>> where
    T: Interaction,
    A: InteractionHandler<T>, 

Returns an InteractionRecipient instance.

Trait Implementations

impl<T, A> ActionRecipient<T> for Address<A> where
    T: Action,
    A: Actor + ActionHandler<T>, 

pub fn act<'life0, 'async_trait>(
    &'life0 mut self,
    msg: T
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Send an Action to an Actor.

pub fn id_ref(&self) -> &Id

pub fn dyn_clone(&self) -> Box<dyn ActionRecipient<T>>

pub fn dyn_hash(&self, state: &mut dyn Hasher)

impl<A: Actor> Clone for Address<A>

pub fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A: Actor> Debug for Address<A>

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<A: Actor> Eq for Address<A>

impl<A: Actor> Hash for Address<A>

pub fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

pub fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given Hasher.

impl<T, A> InteractionRecipient<T> for Address<A> where
    T: Interaction,
    A: Actor + InteractionHandler<T>, 

pub fn interact<'life0, 'async_trait>(
    &'life0 mut self,
    msg: T
) -> Pin<Box<dyn Future<Output = Result<T::Output, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Interact with an Actor.

pub fn id_ref(&self) -> &Id

pub fn dyn_clone(&self) -> Box<dyn InteractionRecipient<T>>

pub fn dyn_hash(&self, state: &mut dyn Hasher)

impl<T, A> Into<Box<dyn ActionRecipient<T> + 'static, Global>> for Address<A> where
    T: Action,
    A: Actor + ActionHandler<T>, 

pub fn into(self) -> Box<dyn ActionRecipient<T>>

Performs the conversion.

impl<T, A> Into<Box<dyn InteractionRecipient<T> + 'static, Global>> for Address<A> where
    T: Interaction,
    A: Actor + InteractionHandler<T>, 

pub fn into(self) -> Box<dyn InteractionRecipient<T>>

Performs the conversion.

impl<A: Actor> PartialEq<Address<A>> for Address<A>

pub fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.

#[must_use]pub fn ne(&self, other: &Rhs) -> bool

This method tests for !=.