Struct ProofTreeStreamer 

pub struct ProofTreeStreamer { /* private fields */ }

Streams partial proof tree updates as nodes resolve.

Implementations

impl ProofTreeStreamer

pub fn new( session_id: impl Into<String>, sink: Arc<ProofTreeUpdateSink>, ) -> Self

Create a new streamer bound to session_id and sink.

pub fn session_id(&self) -> &str

Return the session identifier for this streamer.

pub fn emit_resolved(&self, goal: &str, depth: usize, peer: Option<String>)

Emit an update for a successfully resolved node.

pub fn emit_unresolved(&self, goal: &str, depth: usize)

Emit an update for a node that could not be resolved.

pub fn emit_final( &self, goal: &str, depth: usize, resolved: bool, peer: Option<String>, )

Emit the final summary update, marking the session as complete.

pub fn stream_tree(&self, tree: &ProofTree)

Walk a completed crate::proof_tree::ProofTree and emit one update per node in BFS (pre-order breadth-first) order, followed by a final update that reflects the overall tree completion status.

pub fn seq(&self) -> u64

Return the current sequence counter value (number of updates emitted so far).