Struct async_events::AsyncEvents

pub struct AsyncEvents<K, T> { /* fields omitted */ }

Allows to create futures which will not complete until an associated event id is resolved. This is useful for creating futures waiting for completion on external events which are driven to completion outside of the current process.

Implementations

impl<K, T> AsyncEvents<K, T>

pub fn new() -> Self

impl<K, V> AsyncEvents<K, V> where
    K: Eq, 

pub fn wait_for_output(&self, event_id: K) -> Observer<V>

A future associated with a peer, which can be resolved using resolve_with. You can call this method repeatedly to create multiple observers waiting for the same event.

Attention: Do not call this method while holding a lock to leases.

pub fn resolve_all_with(&self, event_ids: &[K], output: V) where
    V: Clone, 

Resolves all the pending futures associated with the given ids.

• event_ids: Observers associated with these ids are resolved
• output: The result these futures will return in their .await call

Trait Implementations

impl<K, T> Default for AsyncEvents<K, T>

fn default() -> Self

Returns the “default value” for a type.