Enum WakeStrategy 

pub enum WakeStrategy {
    Poll {
        interval: Duration,
    },
    Notify(Arc<RwLock<HashMap<String, Arc<Notify>>>>),
}

Strategy for waking consumers when new events arrive

Variants

Poll

Poll periodically for new events

Fields

interval: Duration

Notify(Arc<RwLock<HashMap<String, Arc<Notify>>>>)

Use async notifications (tokio::sync::Notify)

Implementations

impl WakeStrategy

pub fn poll(interval: Duration) -> Self

Create a polling wake strategy with the given interval

pub fn notify() -> Self

Create a notification-based wake strategy

pub async fn wait(&self, stream: &str)

Wait for new events on a stream

pub fn notify_stream(&self, stream: &str)

Notify all consumers waiting on a stream

This is a no-op for Poll strategy.

pub fn notify_all(&self)

Notify all consumers on all streams

This is a no-op for Poll strategy.

Trait Implementations

impl Clone for WakeStrategy

fn clone(&self) -> WakeStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WakeStrategy

fn default() -> Self

Returns the “default value” for a type.