Struct ChannelInterceptor 

pub struct ChannelInterceptor { /* private fields */ }

A BspInterceptor that forwards every event onto a tokio::sync::broadcast channel — every GUI / CLI / TUI then just subscribes.

Send failures (no active receivers, or a lagging receiver) are ignored by design: telemetry must never backpressure the scheduler.

Implementations

impl ChannelInterceptor

pub fn new(capacity: usize) -> Self

Creates an interceptor and its broadcast channel with the given capacity.

pub fn subscribe(&self) -> Receiver<BspEvent>

Subscribes to the event stream.

Trait Implementations

impl BspInterceptor for ChannelInterceptor

Available on crate feature tokio only.

fn on_superstep_start(&self, step: u64, frontier: &[NodeId])

A superstep is about to execute the given frontier.

fn on_node_start(&self, node_id: NodeId, name: &str)

A node began executing.

fn on_node_complete(&self, node_id: NodeId, name: &str, duration: Duration)

A node finished executing (including skip-bypassed executions, which report a zero duration).

fn on_node_error(&self, node_id: NodeId, name: &str, err: &BspError)

A node’s failure is propagating (after any retries were exhausted or classified fatal). Also fires when the failure is routed to an error edge.

fn on_node_retry( &self, node_id: NodeId, attempt: u32, wait: Duration, err: &BspError, )

A node failure was classified transient; the engine will re-execute after wait. attempt is the 1-based retry number.

fn on_edge_taken(&self, source: NodeId, target: NodeId, condition_label: &str)

An edge fired: its condition matched and a token was emitted toward target. This is what makes a GUI alive — highlight the active edge.

fn on_loop_iteration(&self, edge: EdgeId, iteration: u64, max: Option<u64>)

A budgeted edge fired against its iteration cap — badge the loop counter.

fn on_suspended(&self, suspensions: &[PendingSuspension])

One or more nodes requested suspension; the run is pausing.

fn on_complete(&self, steps: u64)

The run completed naturally after steps supersteps.