Struct freactor::Freactor

pub struct Freactor {
    pub funcs: Arc<HashMap<String, Arc<dyn Fn(Arc<Mutex<State>>) -> Pin<Box<dyn Future<Output = Result<Code, Box<dyn Error + Send>>> + Send + 'static>> + Send + Sync>>>,
    pub flow_config: Arc<FlowConfig>,
}

Fields

funcs: Arc<HashMap<String, Arc<dyn Fn(Arc<Mutex<State>>) -> Pin<Box<dyn Future<Output = Result<Code, Box<dyn Error + Send>>> + Send + 'static>> + Send + Sync>>>

flow_config: Arc<FlowConfig>

Implementations

impl Freactor

pub fn new( func_map: Vec<(String, Arc<dyn Fn(Arc<Mutex<State>>) -> Pin<Box<dyn Future<Output = Result<Code, Box<dyn Error + Send>>> + Send + 'static>> + Send + Sync>)>, flow_config_str: String, ) -> Self

pub async fn run( &self, task_name: &str, states: Arc<Mutex<State>>, ) -> Result<(), Box<dyn Error + Send>>

Trait Implementations

impl Clone for Freactor

fn clone(&self) -> Freactor

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.