Trait Notifying 

pub trait Notifying: Store {
    // Required method
    fn wait_wakeup<'life0, 'life1, 'async_trait>(
        &'life0 self,
        queues: &'life1 [String],
        timeout: Duration,
    ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StoreError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

push wakeups push wakeup: sub-poll-interval latency when the store can signal new work. A missed or spurious notification costs LATENCY, never correctness — the poll fallback always stands (River’s layered-fetch lesson).

Required Methods

fn wait_wakeup<'life0, 'life1, 'async_trait>( &'life0 self, queues: &'life1 [String], timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Wait up to timeout for a hint that work may be available. An empty queues slice matches ANY queue (the UI’s one-subscription case, bounded live-control contract). Returns the waking queue’s name, or None on timeout. Wakeups may be spurious; callers admit either way when their poll timer expires — a wakeup only shortcuts it.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors