Struct VisibleMessageStream 

pub struct VisibleMessageStream { /* private fields */ }

Per-run message-only replay and broadcast state.

The replay is intentionally not byte-capped: it contains only visible text generated by the current run and remains authoritative until durable history is acknowledged. Silently evicting it would make late subscribers lose text.

Implementations

impl VisibleMessageStream

pub fn new() -> Self

pub fn subscribe_with_snapshot( &self, ) -> (Receiver<VisibleMessageEvent>, VisibleMessageSnapshot)

Subscribe before taking the snapshot. Concurrent events are either in the snapshot or queued with a greater version, never neither.

pub fn begin_round(&self, round_count: u32)

pub fn start(&self, message_id: String, created_at: DateTime<Utc>)

Start one provider response. Previous segments remain replayable until an explicit discard or the durable-history barrier; a later attempt in the same round does not prove the earlier segment was rolled back.

pub fn append(&self, content: String)

Append visible assistant text. Legacy producers without an explicit start receive a host-minted temporary identity and reconcile on history commit.

pub fn discard(&self, message_id: &str)

pub fn mark_terminal(&self, reason: impl Into<String>)

pub fn history_committed(&self)

Clear replay only after durable history has actually been published.

Trait Implementations

impl Debug for VisibleMessageStream

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

Formats the value using the given formatter.

impl Default for VisibleMessageStream

fn default() -> Self

Returns the “default value” for a type.