Struct TurnPublisher 

pub struct TurnPublisher { /* private fields */ }

Publishes a turn’s events through a sink, under the PublicationGate.

The gate is the reason this type exists rather than a bare sink: the orchestrator advances the phase as it goes, and a block offered too early is dropped instead of published, whatever the caller intended.

Implementations

impl TurnPublisher

pub fn new(sink: Arc<dyn TurnSink>) -> Self

A publisher writing to sink.

pub fn null() -> Self

A publisher that drops everything.

pub const fn is_live(&self) -> bool

Whether anything is listening: false for Self::null.

compose asks before it goes looking for a streaming-capable provider, because a turn nobody is watching has no reason to prefer one.

pub fn phase(&self) -> TurnPhase

The phase the gate is at.

pub fn phase_reached(&self, phase: TurnPhase)

Announces a phase and moves the gate to it.

pub fn publish_step(&self, step: Step)

Publishes one step of the understanding. Steps are not outcomes, so the gate never holds them back.

pub fn step_said(&self, step: Step, text: String)

Publishes a step as a model said it.

pub fn block(&self, block: &ResponseBlock) -> bool

Publishes one block if the gate admits it, and returns whether it went out.

pub fn blocks(&self, turn: &AssistantTurn)

Publishes every block of a composed turn, in order.

pub fn completed(&self, turn: &AssistantTurn)

Ends the stream with the turn that was persisted.

pub fn failed(&self, code: impl Into<String>)

Ends the stream with a stable failure code.

Trait Implementations

impl Debug for TurnPublisher

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

Formats the value using the given formatter.

impl StepSink for TurnPublisher

fn step(&self, step: Step)

Delivers one step. Implementations must not block.