Struct actix::dev::ContextParts

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

Methods

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<Item = (), Error = (), Actor = A> + 'static,

Spawn new future to this context.

pub fn wait<F>(&mut self, f: F) where     F: ActorFuture<Item = (), Error = (), Actor = A> + '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