Struct StreamCollector 

pub struct StreamCollector { /* private fields */ }

A higher-level projection over a recorded GraphEvent stream.

Where GraphEventRecorder hands back raw events, StreamCollector slices them into the views a test usually wants: the executed-node order, the nodes that wrote state, the (from, to) routes the executor selected, the emitted interrupts, the persisted-checkpoint count, and any custom node writes.

Implementations

impl StreamCollector

pub fn new(events: Vec<GraphEvent>) -> Self

Wraps an owned event sequence for projection.

pub fn events(&self) -> &[GraphEvent]

The recorded events, unprojected.

pub fn node_order(&self) -> Vec<NodeId>

The executed-node order (one entry per GraphEvent::NodeCompleted).

pub fn updates(&self) -> Vec<NodeId>

The nodes that wrote state, in order (one entry per StateUpdated).

pub fn routes(&self) -> Vec<(NodeId, NodeId)>

The (from, to) routes the executor selected, in order.

pub fn interrupts(&self) -> Vec<Interrupt>

The interrupts emitted during the run, in order.

pub fn checkpoint_count(&self) -> usize

The number of persisted checkpoints (one per CheckpointSaved).

pub fn custom(&self) -> Vec<(String, Value)>

The custom node writes, as (name, data) pairs in order.

Trait Implementations

impl Clone for StreamCollector

fn clone(&self) -> StreamCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for StreamCollector

fn default() -> StreamCollector

Returns the “default value” for a type.