Struct DisappearingChannels 

pub struct DisappearingChannels {
    pub receiver: Arc<Mutex<Receiver<()>>>,
    /* private fields */
}

Dedicated wake channel for the disappearing-messages worker.

A capacity-1 mpsc carrying unit () “recompute the next expiry deadline” nudges. Capacity 1 is deliberate: the worker drains and re-queries the DB on every wake, so a single pending nudge already captures “something changed” — more would be redundant. It also bounds memory to one slot even when no worker is consuming the channel (e.g. the disappearing worker is disabled or disable_workers is set), so rearm() can never accumulate without bound.

Fields

receiver: Arc<Mutex<Receiver<()>>>

Implementations

impl DisappearingChannels

pub fn new() -> Self

pub fn rearm(&self)

Wake the worker to recompute its next-expiry deadline. Best-effort and non-blocking: if a nudge is already queued (slot full) or no worker is consuming, the send is dropped — the worker recomputes from the DB on its next wake regardless, so a dropped duplicate nudge changes nothing.

Trait Implementations

impl Clone for DisappearingChannels

fn clone(&self) -> DisappearingChannels

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DisappearingChannels

fn default() -> Self

Returns the “default value” for a type.