Struct actix::Context
[−]
[src]
pub struct Context<A> where
A: Actor<Context = Context<A>>, { /* fields omitted */ }
Actor execution context
Trait Implementations
impl<A> ActorContext<A> for Context<A> where
A: Actor<Context = Self>,
[src]
A: Actor<Context = Self>,
fn stop(&mut self)
[src]
Stop actor execution
fn terminate(&mut self)
[src]
Terminate actor execution
fn state(&self) -> ActorState
[src]
Actor execution state
fn alive(&self) -> bool
[src]
Check if execution context is alive
fn address<Address>(&mut self) -> Address where
A: ActorAddress<A, Address>,
[src]
A: ActorAddress<A, Address>,
Get actor address
impl<A> AsyncContext<A> for Context<A> where
A: Actor<Context = Self>,
[src]
A: Actor<Context = Self>,
fn spawn<F>(&mut self, fut: F) -> SpawnHandle where
F: ActorFuture<Item = (), Error = (), Actor = A> + 'static,
[src]
F: ActorFuture<Item = (), Error = (), Actor = A> + 'static,
Spawn async future into context. Returns handle of the item, could be used for cancelling execution. Read more
fn wait<F>(&mut self, fut: F) where
F: ActorFuture<Item = (), Error = (), Actor = A> + 'static,
[src]
F: ActorFuture<Item = (), Error = (), Actor = A> + 'static,
Spawn future into the context. Stop processing any of incoming events until this future resolves. Read more
fn cancel_future(&mut self, handle: SpawnHandle) -> bool
[src]
Cancel future. idx is a value returned by spawn
method.
fn add_future<F>(&mut self, fut: F) where
F: Future + 'static,
F::Item: ResponseType,
A: Handler<F::Item, F::Error>,
[src]
F: Future + 'static,
F::Item: ResponseType,
A: Handler<F::Item, F::Error>,
This method allow to handle Future in similar way as normal actor messages. Read more
fn add_stream<S>(&mut self, fut: S) where
S: Stream + 'static,
S::Item: ResponseType,
A: Handler<S::Item, S::Error> + StreamHandler<S::Item, S::Error>,
[src]
S: Stream + 'static,
S::Item: ResponseType,
A: Handler<S::Item, S::Error> + StreamHandler<S::Item, S::Error>,
This method is similar to add_future
but works with streams. Read more
fn notify<M, E>(&mut self, msg: M, after: Duration) -> SpawnHandle where
A: Handler<M, E>,
M: ResponseType + 'static,
E: 'static,
[src]
A: Handler<M, E>,
M: ResponseType + 'static,
E: 'static,
Send message msg
to self after specified period of time. Returns spawn handle which could be used for cancelation. Read more
fn run_later<F>(&mut self, dur: Duration, f: F) -> SpawnHandle where
F: FnOnce(&mut A, &mut A::Context) + 'static,
[src]
F: FnOnce(&mut A, &mut A::Context) + 'static,
Execute closure after specified period of time within same Actor and Context
impl<A> AsyncContextApi<A> for Context<A> where
A: Actor<Context = Self>,
[src]
A: Actor<Context = Self>,
fn address_cell(&mut self) -> &mut ActorAddressCell<A>
[src]
impl<A> Debug for Context<A> where
A: Actor<Context = Self>,
[src]
A: Actor<Context = Self>,
impl<A, M> ToEnvelope<A, M> for Context<A> where
A: Actor<Context = Context<A>> + Handler<M>,
M: ResponseType + Send + 'static,
M::Item: Send,
M::Error: Send,
[src]
A: Actor<Context = Context<A>> + Handler<M>,
M: ResponseType + Send + 'static,
M::Item: Send,
M::Error: Send,