Struct actix::dev::ContextParts

pub struct ContextParts<A>
where
    A: Actor,
    A::Context: AsyncContext<A>,
{ /* private fields */ }

Implementations

impl<A> ContextParts<A>

where A: Actor, A::Context: AsyncContext<A>,

pub fn new(addr: AddressSenderProducer<A>) -> Self

Create new ContextParts instance

pub fn stop(&mut self)

Initiate stop process for actor execution

Actor could prevent stopping by returning false from Actor::stopping() method.

pub fn terminate(&mut self)

Terminate actor execution

pub fn state(&self) -> ActorState

Actor execution state

pub fn waiting(&self) -> bool

Is context waiting for future completion

pub fn curr_handle(&self) -> SpawnHandle

Handle of the running future

pub fn spawn<F>(&mut self, fut: F) -> SpawnHandle

where F: ActorFuture<A, Output = ()> + 'static,

Spawn new future to this context.

pub fn wait<F>(&mut self, f: F)

where F: ActorFuture<A, Output = ()> + 'static,

Spawn new future to this context and wait future completion.

During wait period actor does not receive any messages.

pub fn cancel_future(&mut self, handle: SpawnHandle) -> bool

Cancel previously scheduled future.

pub fn capacity(&mut self) -> usize

pub fn set_mailbox_capacity(&mut self, cap: usize)

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

pub fn started(&mut self) -> bool

pub fn connected(&self) -> bool

Are any senders connected

Trait Implementations

impl<A> Debug for ContextParts<A>

where A: Actor, A::Context: AsyncContext<A>,

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

Formats the value using the given formatter.