Method wait

flow-rs/src/graph/context.rs:39–56

(&self)

        self.is_closed.load(Ordering::Relaxed)
    }
    pub async fn wait(&self) {
        let mut listener = None;

        loop {
            if self.is_closed.load(Ordering::Relaxed) {
                return;
            }

            match listener.take() {
                None => {
                    listener = Some(self.lock_ops.listen());
                }
                Some(l) => {
                    l.await;
                }
            }
        }
    }
}

lazy_static::lazy_static! {