Struct ServiceRealtimeAdapter 

pub struct ServiceRealtimeAdapter<S: RealtimeLlmService> { /* private fields */ }

Adapts any RealtimeLlmService connector into the pipeline’s RealtimeLlm + RealtimeKickoff surface. See the module docs.

Implementations

impl<S: RealtimeLlmService> ServiceRealtimeAdapter<S>

pub fn new(inner: S) -> Self

Wrap a realtime connector.

pub fn into_inner(self) -> S

Unwrap back to the underlying connector.

Trait Implementations

impl<S: RealtimeLlmService> RealtimeKickoff for ServiceRealtimeAdapter<S>

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

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

Trigger an initial model turn so the bot speaks first.

impl<S: RealtimeLlmService> RealtimeLlm for ServiceRealtimeAdapter<S>

fn connect<'life0, 'async_trait>( &'life0 mut self, setup: RealtimeSetup, ) -> Pin<Box<dyn Future<Output = Result<(), FlowcatError>> + Send + 'async_trait>>

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

Open the session with the initial system prompt + tools + audio rates.

fn send_audio<'life0, 'async_trait>( &'life0 mut self, chunk: AudioChunk, ) -> Pin<Box<dyn Future<Output = Result<(), FlowcatError>> + Send + 'async_trait>>

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

Stream a chunk of caller audio (16 kHz PCM) to the model.

fn update_system<'life0, 'async_trait>( &'life0 mut self, prompt: String, tools: Vec<ToolDecl>, ) -> Pin<Box<dyn Future<Output = Result<(), FlowcatError>> + Send + 'async_trait>>

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

Replace the active system prompt and tool set (on a brain transition).

fn send_tool_result<'life0, 'async_trait>( &'life0 mut self, id: String, result: Value, ) -> Pin<Box<dyn Future<Output = Result<(), FlowcatError>> + Send + 'async_trait>>

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

Return the result of a tool/function call back to the model.

fn next_event<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<RealtimeEvent>> + Send + 'async_trait>>

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

Await the next model event, or None when the session has closed.

fn input_sample_rate(&self) -> u32

The PCM sample rate (Hz) the model expects on its audio input. The s2s pipeline resamples caller audio to this before send_audio and advertises it to the model in RealtimeSetup::input_sample_rate. Default 16 kHz (Gemini Live); a provider that requires a different input rate (OpenAI Realtime needs ≥ 24 kHz) overrides this.

fn event_notify(&self) -> Option<Arc<Notify>>

A Notify that fires whenever a model event becomes available, so a consumer can await readiness WITHOUT holding this session’s lock across next_event (which would starve send_audio). None (the default) means the provider doesn’t support the non-blocking path and the consumer falls back to the blocking next_event. GeminiLive returns Some.

fn poll_event<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = PollEvent> + Send + 'async_trait>>

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

Non-blocking sibling of next_event: return the next event if one is immediately ready, else PollEvent::Pending (the caller should event_notify().notified().await — lock released — then re-poll). The default blocks (legacy behaviour); providers that return a real event_notify MUST override this to be genuinely non-blocking.