Struct StreamEmitter 

pub struct StreamEmitter { /* private fields */ }

The algebraic effect handler — bridges flow execution to EventBus streaming.

In algebraic effects terms, this is the Handler that captures the evaluation context E[perform(Emit(v))] and translates it to: Handler(v, λx. E[x]) → publish(“flow.stream.{id}”, v) ; resume(x)

Implementations

impl StreamEmitter

pub fn new(trace_id: u64, flow_name: &str) -> Self

pub fn emit(&mut self, step_name: &str, content: &str)

perform(Emit(content)) — the algebraic effect operation. Pure: records the intent without side effects. The handler (publish_to_bus) materializes it. perform(Emit(content)) — step-level algebraic effect. Epistemic state: “speculate” (unvalidated LLM output).

pub fn emit_with_context( &mut self, step_name: &str, content: &str, epistemic_state: &str, effect_row: &str, nav_ctx: Option<&NavigationContext>, )

perform(Emit(content)) with full epistemic/navigation context.

pub fn emit_pix_navigate( &mut self, step_name: &str, content: &str, pix_ref: &str, trail: Vec<String>, depth: u32, )

Emit PIX navigate result — epistemic state “believe” (external source, not yet validated). PIX retrieval: EffectRow = <io, epistemic:believe>

pub fn emit_mdn_traverse( &mut self, step_name: &str, content: &str, corpus_ref: &str, edge_type: &str, depth: u32, )

Emit MDN graph traverse result — epistemic state “believe” with edge type. MDN retrieval: EffectRow = <io, network, epistemic:believe>

pub fn finalize(&mut self)

Mark stream as complete — emit final sentinel. On finalization, if all anchors pass, epistemic state promotes to “know”.

pub fn finalize_with_epistemic( &mut self, epistemic_state: &str, effect_row: &str, )

Finalize with explicit epistemic state (e.g., “believe” if anchors didn’t run).

pub fn publish_to_bus(&self, bus: &EventBus)

Materialize: publish all buffered tokens to the EventBus. This is the natural transformation h: F_Σ(B) → M_IO(B).

pub fn emit_chunks(&mut self, step_name: &str, chunks: &[String])

Emit token-level chunks for a step — coinductive stream observations. Each chunk: epistemic_state = “speculate”, effect_row = <io, epistemic:speculate>.

pub fn token_count(&self) -> u64

pub fn tokens(&self) -> &[StreamToken]