Struct actix::WeakRecipient

pub struct WeakRecipient<M>
where
    M: Message + Send,
    M::Result: Send,
{ /* private fields */ }

A weakly referenced counterpart to Recipient<M>

Implementations

impl<M> WeakRecipient<M>

where M: Message + Send, M::Result: Send,

pub fn upgrade(&self) -> Option<Recipient<M>>

Attempts to upgrade the WeakRecipient<M> pointer to an Recipient<M>, similar to WeakAddr<A>

Examples found in repository

examples/weak_recipient.rs (line 28)

    fn send_tick(&mut self, _ctx: &mut Context<Self>) {
        for client in self.clients.iter() {
            if let Some(client) = client.upgrade() {
                client.do_send(TimePing(Instant::now()));
                println!("⏰ sent ping to client {:?}", client);
            } else {
                println!("⏰ client can no longer be upgraded");
            }
        }

        // gc
        self.clients = self
            .clients
            .drain(..)
            .filter(|c| c.upgrade().is_some())
            .collect();
        println!("⏰ service has {} clients", self.clients.len());
    }

Trait Implementations

impl<M> Clone for WeakRecipient<M>

where M: Message + Send, M::Result: Send,

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M> Debug for WeakRecipient<M>

where M: Message + Send, M::Result: Send,

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

Formats the value using the given formatter.

impl<A, M: Message + Send + 'static> From<Addr<A>> for WeakRecipient<M>

where A: Handler<M> + Actor, M::Result: Send, A::Context: ToEnvelope<A, M>,

fn from(addr: Addr<A>) -> WeakRecipient<M>

Converts to this type from the input type.

impl<M> From<Recipient<M>> for WeakRecipient<M>

where M: Message + Send, M::Result: Send,

fn from(recipient: Recipient<M>) -> Self

Converts to this type from the input type.

impl<A, M: Message + Send + 'static> From<WeakAddr<A>> for WeakRecipient<M>

where A: Handler<M> + Actor, M::Result: Send, A::Context: ToEnvelope<A, M>,

fn from(addr: WeakAddr<A>) -> WeakRecipient<M>

Converts to this type from the input type.