Enum StreamEvent 

pub enum StreamEvent<S: StateSchema> {
    Start(S),
    EnterNode(String, S),
    NodeComplete(String, StateUpdate<S>),
    StateUpdate(S),
    End(S),
}

StreamEvent - Event for streaming execution

Variants

Start(S)

Execution started with the initial state.

EnterNode(String, S)

A node was entered with the current state.

NodeComplete(String, StateUpdate<S>)

A node completed with its state update.

StateUpdate(S)

The state was updated after applying a reducer.

End(S)

Execution finished with the final state.

Implementations

impl<S: StateSchema> StreamEvent<S>

pub fn start(state: S) -> Self

Construct a Start stream event.

pub fn enter_node(name: impl Into<String>, state: S) -> Self

Construct an EnterNode stream event.

pub fn node_complete(name: impl Into<String>, update: StateUpdate<S>) -> Self

Construct a NodeComplete stream event.

pub fn state_update(state: S) -> Self

Construct a StateUpdate stream event.

pub fn end(state: S) -> Self

Construct an End stream event.

Trait Implementations

impl<S: Clone + StateSchema> Clone for StreamEvent<S>

fn clone(&self) -> StreamEvent<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + StateSchema> Debug for StreamEvent<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.