rs-flow 0.5.0

Create flows to execute based in components created and yours connections
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use std::{fmt::Debug, sync::RwLock};

use crate::error::{FlowError, Result};

pub(crate) struct Global<G>(RwLock<G>);

impl<G> Global<G>
    where G: Send + Sync
{

    pub(crate) fn from_data(data: G) -> Self {
        Global(RwLock::new(data))
    }

    pub(crate) fn with_global<R>(&self, call: impl FnOnce(&G) -> R) -> Result<R> {
        match self.0.read() {
            Ok(global) => Ok(call(&global)),
            Err(_) => Err(FlowError::CannotAccessGlobal)
        }
    }

    pub(crate) fn with_mut_global<R>(&self,  call: impl FnOnce(&mut G) -> R) -> Result<R> {
        match self.0.write() {
            Ok(mut global) => Ok(call(&mut global)),
            Err(_) => Err(FlowError::CannotAccessGlobal)
        }
    }

    pub(crate) fn take(self) -> G {
        self.0.into_inner().expect("Global have multiple owners")
    }

}

impl<GD> Debug for Global<GD> {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_tuple("Global").finish()
    }
}