Struct meio::address::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 attach<S>(&mut self, stream: S) -> JoinHandle<()> where
    A: ActionHandler<S::Item>,
    S: Stream + Send + Unpin + 'static,
    S::Item: Action, 

Attaches a Stream of event to an Actor.

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

Generates ActionRecipient.

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

Generates InteractionRecipient.

pub fn controller(&self) -> Controller

Gives a Controller of that entity.

Methods from Deref<Target = Controller>

pub fn id(&self) -> Id

Returns Id of the controller.

pub fn shutdown(&mut self)

Start shutdown process for the Actor.

pub async fn join<'_>(&'_ mut self)

Waits when the Actor will be terminated.

Trait Implementations

impl<A, I> ActionPerformer<I> for Address<A> where
    A: Actor,
    A: ActionHandler<I>,
    I: Action, 

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

Send Action message to an Actor.

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

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

type Target = Controller

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

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

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

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

impl<A, I> From<Address<A>> for ActionRecipient<I> where
    A: Actor,
    A: ActionHandler<I>,
    I: Action, 

fn from(address: Address<A>) -> Self

Performs the conversion.

impl<A, I> From<Address<A>> for InteractionRecipient<I> where
    A: Actor,
    A: InteractionHandler<I>,
    I: Interaction, 

fn from(address: Address<A>) -> Self

Performs the conversion.

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

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

Feeds this value into the given Hasher.

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

Feeds a slice of this type into the given Hasher.

impl<A, I> InteractionPerformer<I> for Address<A> where
    A: Actor,
    A: InteractionHandler<I>,
    I: Interaction, 

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

Send Interaction message to an Actor and wait for the response.

impl<A: Actor> Into<Controller> for Address<A>

fn into(self) -> Controller

Performs the conversion.

impl<T, A> Link<T> for Address<A> where
    T: From<Address<A>>,
    A: Actor, 

fn link(&self) -> T

Gets a Link to an Actor.

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

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

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

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

This method tests for !=.