Struct ThinkingStep 

pub struct ThinkingStep<'a, P: EventProducer<StateT>, StateT: AgentState = JsonValue> { /* private fields */ }

Helper for managing thinking block boundaries (chain-of-thought steps).

This struct wraps a thinking block with ThinkingStart and ThinkingEnd events. Inside a thinking step, you can emit thinking content using ThinkingMessageStream.

Example

// Start a thinking step with optional title
let step = ThinkingStep::start(&producer, Some("Analyzing user query")).await?;

// Emit thinking content inside the step
let thinking = ThinkingMessageStream::start(step.producer()).await?;
thinking.content("First, let me consider...").await?;
thinking.end().await?;

// End the thinking step
step.end().await?;

Implementations

impl<'a, P: EventProducer<StateT>, StateT: AgentState> ThinkingStep<'a, P, StateT>

pub async fn start( producer: &'a P, title: Option<impl Into<String>>, ) -> Result<Self, ServerError>

Start a new thinking step.

Emits a ThinkingStart event with an optional title.

pub async fn end(self) -> Result<(), ServerError>

End the thinking step.

Emits a ThinkingEnd event. Consumes the step to prevent reuse.

pub fn producer(&self) -> &'a P

Get a reference to the underlying producer.

Use this to create ThinkingMessageStream instances inside the step.