Struct ContextFut

pub struct ContextFut<A, C>
where
    C: AsyncContextParts<A> + Unpin,
    A: Actor<Context = C>,
{ /* private fields */ }

Implementations

impl<A, C> ContextFut<A, C>

where C: AsyncContextParts<A> + Unpin, A: Actor<Context = C>,

pub fn new(ctx: C, act: A, mailbox: Mailbox<A>) -> Self

pub fn ctx(&mut self) -> &mut C

pub fn address(&self) -> Addr<A>

pub fn alive(&mut self) -> bool

pub fn restart(&mut self) -> bool

where A: Supervised,

Restarts the AsyncContext of this ContextFut returning whether the Context was restarted.

Restarting the Context means:

• canceling all the ActorFutures spawned by the AsyncContext;
• clearing the ActorFuture await queue of the AsyncContext;
• changing the Actor state to ActorState::Running;
• calling Supervised::restarting on the Actor.

Restart may fail only if the Mailbox is not connected.

Trait Implementations

impl<A, C> Debug for ContextFut<A, C>

where C: AsyncContextParts<A> + Unpin, A: Actor<Context = C>,

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

Formats the value using the given formatter.

impl<A, C> Drop for ContextFut<A, C>

where C: AsyncContextParts<A> + Unpin, A: Actor<Context = C>,

fn drop(&mut self)

Executes the destructor for this type.