Struct ChatResponseWriter 

pub struct ChatResponseWriter { /* private fields */ }

The sending side of a ChatResponseHandle, held by the Python bridge thread that drives the SDK’s async iterator.

Implementations

impl ChatResponseWriter

pub async fn send_text(&self, text: String) -> Result<(), WriterError>

Send a text token.

Errors

Returns WriterError if the receiver has been dropped.

pub async fn send_thought(&self, thought: String) -> Result<(), WriterError>

Send a thinking token.

Errors

Returns WriterError if the receiver has been dropped.

pub async fn send_tool_call( &self, event: ToolCallEvent, ) -> Result<(), WriterError>

Send a tool call event.

Errors

Returns WriterError if the receiver has been dropped.

pub async fn send_error(&self, error: StreamError) -> Result<(), WriterError>

Send an error.

Errors

Returns WriterError if the receiver has been dropped.

pub async fn send_event(&self, event: ResponseEvent) -> Result<(), WriterError>

Send a response event.

Errors

Returns WriterError if the receiver has been dropped.

pub async fn send_step(&self, step: Step) -> Result<(), WriterError>

Send a step.

Errors

Returns WriterError if the receiver has been dropped.

pub async fn send_chunk(&self, chunk: StreamChunk) -> Result<(), WriterError>

Send a unified stream chunk.

Errors

Returns WriterError if the receiver has been dropped.

pub fn set_usage(&self, usage: UsageMetadata)

Store usage metadata in the shared state so the handle can read it after the stream completes.

pub fn set_structured_output(&self, value: Value)

Store structured output in the shared state so the handle can read it after the stream completes.