Struct ThinkingMessageStream 

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

Helper for streaming thinking content (extended thinking / chain-of-thought).

This struct manages the lifecycle of streaming thinking content. Unlike MessageStream, thinking messages don’t have IDs as they’re ephemeral.

Example

let thinking = ThinkingMessageStream::start(&producer).await?;
thinking.content("Let me analyze this...").await?;
thinking.content("The key factors are...").await?;
thinking.end().await?;

Implementations

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

pub async fn start(producer: &'a P) -> Result<Self, ServerError>

Start a new thinking message stream.

Emits a ThinkingTextMessageStart event.

pub async fn content(&self, delta: impl Into<String>) -> Result<(), ServerError>

Append content to the thinking message.

Emits a ThinkingTextMessageContent event with the given delta. Unlike regular messages, empty deltas are allowed for thinking content.

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

End the thinking message stream.

Emits a ThinkingTextMessageEnd event. Consumes the stream to prevent further content being added.