Struct apalis_core::worker::Context

pub struct Context<W: Actor> { /* private fields */ }

Available on crate feature worker only.

Context for execution of actor

Implementations

impl<W: Actor> Context<W>

pub fn new(addr: Addr<W>, handle: JoinHandle<()>) -> Self

Default constructor

pub fn addr(&self) -> Addr<W>

Gets an address of current worker

pub fn recipient<M>(&self) -> Recipient<M>where
    M: Message + Send + 'static,
    W: ContextHandler<M>,
    M::Result: Send,

Gets an recipient for current worker with specified message type

pub fn notify<M>(&self, message: M)where
    M: Message + Send + 'static,
    W: ContextHandler<M>,
    M::Result: Send,

Sends worker specified message

pub fn notify_later<M>(&self, message: M, later: Duration)where
    M: Message + Send + 'static,
    W: Handler<M>,
    M::Result: Send,

Sends actor specified message in some time

pub fn notify_every<M>(&self, every: Duration)where
    M: Message + Default + Send + 'static,
    W: Handler<M>,
    M::Result: Send,

Sends actor specified message in a loop with specified duration

pub fn notify_with<M, S>(&self, stream: S)where
    M: Message + Send + 'static,
    S: Stream<Item = M> + Unpin + Send + 'static,
    W: Handler<M>,
    M::Result: Send,

Notifies actor with items from stream

Trait Implementations

impl<W: Debug + Actor> Debug for Context<W>

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

Formats the value using the given formatter.