Enum StreamEvent 

pub enum StreamEvent<S: GraphState> {
    NodeStart {
        node_id: String,
        state: S,
    },
    NodeEnd {
        node_id: String,
        state: S,
        command: Command,
    },
    End {
        final_state: S,
    },
    Error {
        node_id: Option<String>,
        error: String,
    },
}

Stream event from graph execution

Variants

NodeStart

A node started executing

Fields

node_id: String

state: S

NodeEnd

A node finished executing

Fields

node_id: String

state: S

command: Command

End

Graph execution completed

Fields

final_state: S

Error

Error occurred

Fields

node_id: Option<String>

error: String

Trait Implementations

impl<S: Clone + GraphState> 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 + GraphState> Debug for StreamEvent<S>

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

Formats the value using the given formatter.