Struct EventDependency

pub struct EventDependency<T: Clone + Send + Sync> {
    pub(crate) event_rx: Receiver<T>,
    pub(crate) match_fn: Box<dyn Fn(&T) -> bool + Send>,
    completed_dependency: Option<T>,
    cancel_receiver: Receiver<()>,
    dependency_name: String,
}

A dependency that listens on a channel for an event that matches what some value it wants.

Fields

event_rx: Receiver<T>

Channel of incoming events

match_fn: Box<dyn Fn(&T) -> bool + Send>

Closure which returns true if the incoming T is the thing that completes this dependency

completed_dependency: Option<T>

The potentially externally completed dependency. If the dependency was seeded from an event message, we can mark it as already done in lieu of other events still pending.

cancel_receiver: Receiver<()>

dependency_name: String

Implementations

impl<T: Clone + Send + Sync + 'static> EventDependency<T>

pub fn new( receiver: Receiver<T>, cancel_receiver: Receiver<()>, dependency_name: String, match_fn: Box<dyn Fn(&T) -> bool + Send>, ) -> Self

Create a new EventDependency

pub fn mark_as_completed(&mut self, dependency: T)

Mark a dependency as completed.

Trait Implementations

impl<T: Clone + Send + Sync + 'static> Dependency<T> for EventDependency<T>

async fn completed(self) -> Option<T>

Complete will wait until it gets some value T then return the value

fn or<D: Dependency<T> + Send + 'static>(self, dep: D) -> OrDependency<T>

where T: Send + Sync + Clone + 'static, Self: Sized + Send + 'static,

Create an or dependency from this dependency and another

fn and<D: Dependency<T> + Send + 'static>(self, dep: D) -> AndDependency<T>

where T: Send + Sync + Clone + 'static, Self: Sized + Send + 'static,

Create an and dependency from this dependency and another