Struct DeferredWriter 

pub struct DeferredWriter { /* private fields */ }

A SessionWriter wrapper that flushes pending context before user content.

Wraps an inner writer and drains a shared PendingContext buffer before forwarding send_audio, send_text, or send_video calls. This ensures model-role context turns arrive in the same burst as user content.

When context is flushed

• send_audio: Context is flushed as send_client_content(drained, false) immediately before the audio frame. Audio goes via realtimeInput (different wire message), so they are two frames — but sent back-to-back with no gap.

• send_text: Context is flushed, then user text is sent. Both go via clientContent, but as separate messages since the user text needs turn_complete: true to trigger a model response.

• send_video: Same as audio — flush then forward.

When context is NOT flushed

send_tool_response, update_instruction, send_client_content, signal_activity_start/end, and disconnect do NOT trigger a flush. These are either internal SDK operations or explicit user control — flushing context before them would be surprising.

Implementations

impl DeferredWriter

pub fn new(inner: Arc<dyn SessionWriter>, pending: Arc<PendingContext>) -> Self

Create a new deferred writer wrapping the given writer.

pub fn pending(&self) -> &Arc<PendingContext>

Get a reference to the shared pending context buffer.

Trait Implementations

impl SessionWriter for DeferredWriter

fn send_audio<'life0, 'async_trait>( &'life0 self, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send raw PCM16 audio bytes.

fn send_text<'life0, 'async_trait>( &'life0 self, text: String, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a text message.

fn send_tool_response<'life0, 'async_trait>( &'life0 self, responses: Vec<FunctionResponse>, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send tool/function call responses back to the model.

fn send_client_content<'life0, 'async_trait>( &'life0 self, turns: Vec<Content>, turn_complete: bool, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send client content (conversation history or context).

fn send_video<'life0, 'async_trait>( &'life0 self, jpeg_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a video/image frame (raw JPEG bytes).

fn update_instruction<'life0, 'async_trait>( &'life0 self, instruction: String, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update the system instruction mid-session.

fn signal_activity_start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal that user speech activity has started.

fn signal_activity_end<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal that user speech activity has ended.

fn disconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gracefully disconnect the session.