[][src]Struct actix_web::actix::Context

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

Actor execution context

Methods

impl<A> Context<A> where
    A: Actor<Context = Context<A>>, 
[src]

pub fn with_receiver(rx: AddressReceiver<A>) -> Context<A>[src]

pub fn run(self, act: A) -> Addr<A>[src]

pub fn into_future(self, act: A) -> ContextFut<A, Context<A>>[src]

pub fn handle(&self) -> SpawnHandle[src]

Handle of the running future

SpawnHandle is the handle returned by AsyncContext::spawn() method.

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

Set mailbox capacity

By default mailbox capacity is 16 messages.

Trait Implementations

impl<A> ActorContext for Context<A> where
    A: Actor<Context = Context<A>>, 
[src]

impl<A, M> ToEnvelope<A, M> for Context<A> where
    A: Actor<Context = Context<A>> + Handler<M>,
    M: Message + Send + 'static,
    <M as Message>::Result: Send
[src]

impl<A> Debug for Context<A> where
    A: Actor<Context = Context<A>>, 
[src]

impl<A> AsyncContext<A> for Context<A> where
    A: Actor<Context = Context<A>>, 
[src]

fn add_stream<S>(&mut self, fut: S) -> SpawnHandle where
    A: StreamHandler<<S as Stream>::Item, <S as Stream>::Error>,
    S: Stream + 'static, 
[src]

This method register stream to an actor context and allows to handle Stream in similar way as normal actor messages. Read more

fn add_message_stream<S>(&mut self, fut: S) where
    A: Handler<<S as Stream>::Item>,
    S: Stream<Error = ()> + 'static,
    <S as Stream>::Item: Message
[src]

This method is similar to add_stream but it skips stream errors. Read more

fn notify<M>(&mut self, msg: M) where
    A: Handler<M>,
    M: Message + 'static, 
[src]

Send message msg to self.

fn notify_later<M>(&mut self, msg: M, after: Duration) -> SpawnHandle where
    A: Handler<M>,
    M: Message + 'static, 
[src]

Send message msg to self after specified period of time. Returns spawn handle which could be used for cancellation. Notification get cancelled if context's stop method get called. Read more

fn run_later<F>(&mut self, dur: Duration, f: F) -> SpawnHandle where
    F: FnOnce(&mut A, &mut <A as Actor>::Context) + 'static, 
[src]

Execute closure after specified period of time within same Actor and Context. Execution get cancelled if context's stop method get called. Read more

fn run_interval<F>(&mut self, dur: Duration, f: F) -> SpawnHandle where
    F: FnMut(&mut A, &mut <A as Actor>::Context) + 'static, 
[src]

Spawns a job to execute the given closure periodically, at a specified fixed interval Read more

impl<A> AsyncContextParts<A> for Context<A> where
    A: Actor<Context = Context<A>>, 
[src]

Auto Trait Implementations

impl<A> !Send for Context<A>

impl<A> !Sync for Context<A>

Blanket Implementations

impl<T, U> Into for T where
    U: From<T>, 
[src]

impl<T> From for T[src]

impl<T, U> TryFrom for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T> Borrow for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> BorrowMut for T where
    T: ?Sized
[src]

impl<T, U> TryInto for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> Erased for T