Struct ConcurrentWorkflowBuilder 

pub struct ConcurrentWorkflowBuilder<TState, TStore = MemoryStore, TParams = DefaultTaskParams>
where
    TState: Clone + Debug + Hash + Eq + Send + Sync + 'static,
    TParams: Clone + Send + Sync + 'static,
    TStore: Clone + Send + Sync + 'static,
{ /* private fields */ }

Builder for creating ConcurrentWorkflow instances with a fluent API

Implementations

impl<TState, TStore, TParams> ConcurrentWorkflowBuilder<TState, TStore, TParams>

where TState: Clone + Debug + Hash + Eq + Send + Sync + 'static, TParams: Clone + Send + Sync + 'static, TStore: Clone + Send + Sync + 'static,

pub fn new(start_state: TState) -> Self

Create a new ConcurrentWorkflowBuilder with a starting state

pub fn register<T>(self, state: TState, task: T) -> Self

where T: Task<TState, TStore, TParams> + Clone + Send + Sync + 'static,

Register a cloneable task for concurrent execution

pub fn register_node<T>(self, state: TState, task: T) -> Self

where T: Task<TState, TStore, TParams> + Clone + Send + Sync + 'static,

👎Deprecated since 0.5.0: Use register instead. The unified register method accepts both Tasks and Nodes.

Register a cloneable node for concurrent execution

Deprecated

This method is deprecated. Use register instead. The unified register method accepts both Tasks and Nodes and provides the same functionality with a cleaner API.

Example

// Instead of:
builder.register_node(state, my_node);

// Use:
builder.register(state, my_node);

pub fn add_exit_state(self, state: TState) -> Self

Add an exit state

pub fn add_exit_states(self, states: Vec<TState>) -> Self

Add multiple exit states

pub fn build(self) -> ConcurrentWorkflow<TState, TStore, TParams>

Build the final ConcurrentWorkflow instance