Struct Address

pub struct Address<A: Agent + ?Sized> { /* private fields */ }

Implementations

impl<A: Agent> Address<A>

pub fn send(&self, msg: impl MessageFor<A>) -> Result<()>

pub async fn join(&mut self) -> Result<AgentStatus>

Important! join must use a reference to allow using it under DerefMut trait

impl<A: Agent> Address<A>

pub fn sender<M>(&self) -> Recipient<M>

where M: MessageFor<A>,

impl<A: Agent> Address<A>

pub fn to_stop_address(self) -> StopAddress<A>

impl<A: Agent> Address<A>

pub fn event<E>(&self, event: E) -> Result<()>

where A: OnEvent<E>, E: TheEvent,

pub fn event_tagged<E, T>(&self, event: E, tag: T) -> Result<()>

where A: OnEvent<E, T>, E: TheEvent, T: Tag,

pub fn recipient<E>(&self) -> Recipient<E>

where A: OnEvent<E>, E: TheEvent,

pub fn recipient_tagged<E, T>(&self, tag: T) -> Recipient<E>

where A: OnEvent<E, T>, E: TheEvent, T: Tag + Sync + Clone,

impl<A: Agent> Address<A>

pub fn interrupt(&self) -> Result<()>

Trait Implementations

impl<A: Agent> AsRef<Address<A>> for AgentSession<A>

fn as_ref(&self) -> &Address<A>

Converts this type into a shared reference of the (usually inferred) input type.

impl<A: Agent> 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> Equip<A> for Address<A>

where A: Agent,

fn equip<E>(self) -> E

where E: From<Address<A>>,

impl<A, E> EventExt<E> for Address<A>

where A: OnEvent<E>, E: TheEvent,

fn event(&self, event: E) -> Result<()>

impl<A: Agent> Interruptor for Address<A>

fn interrupt(&self)

fn interrupt_with_level(&self, level: InterruptionLevel)

impl<A, M> Sender<M> for Address<A>

where A: Agent, M: MessageFor<A>,

fn send(&self, input: M) -> Result<()>

Sends an event (data) to a recipient.

fn notifier(self, message: M) -> TypedNotifier<M>

where Self: Sized + 'static,

impl<A: Agent> ToAddress<A> for Address<A>

fn to_address(&self) -> Address<A>

impl<A, M> ToRecipient<M> for Address<A>

where A: OnEvent<M>, M: Send + 'static,

fn to_recipient(&self) -> Recipient<M>