Struct apalis_core::worker::Recipient

pub struct Recipient<M: Message>(_);

Available on crate feature worker only.

Address of actor. Can be used to send messages to it.

Implementations

impl<M> Recipient<M>where
    M: Message + Send,
    M::Result: Send,

pub async fn send(&self, m: M) -> Option<M::Result>

Send message to actor

Examples found in repository

src/worker/deadlock.rs (line 148)

    async fn on_start(&mut self, ctx: &mut Context<Self>) {
        let recipient = ctx.recipient::<Reminder>();
        drop(task::spawn(async move {
            loop {
                recipient.send(Reminder).await;
                time::sleep(Duration::from_millis(100)).await
            }
        }));
    }

src/worker/broker.rs (line 46)

    pub async fn issue_send<M: BrokerMessage + Send + Sync>(&self, m: M) {
        let entry = if let Entry::Occupied(entry) = self.message_entry(TypeId::of::<M>()) {
            entry
        } else {
            return;
        };
        let send = entry.get().iter().filter_map(|(_, recipient)| {
            recipient
                .downcast_ref::<Recipient<M>>()
                .map(|recipient| recipient.send(m.clone()))
        });
        drop(future::join_all(send).await);
    }

Trait Implementations

impl<M> Debug for Recipient<M>where
    M: Message + Send,

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

Formats the value using the given formatter.