Struct hotshot_task::dependency::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>,
}

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.

Implementations

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

pub fn new( receiver: Receiver<T>, 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