Struct UserBotLatencyObserver 

pub struct UserBotLatencyObserver { /* private fields */ }

Measures the user-stop → first-bot-audio latency (TTFB of the bot’s reply). Mirrors pipecat UserBotLatencyObserver.

Implementations

impl UserBotLatencyObserver

pub fn new() -> Self

pub fn last_latency_ns(&self) -> Option<i64>

The most recently measured user-stop → bot-audio latency in ns, if any.

Trait Implementations

impl Default for UserBotLatencyObserver

fn default() -> Self

Returns the “default value” for a type.

impl FrameObserver for UserBotLatencyObserver

fn on_process<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, e: &'life1 FrameEvent<'life2>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

A processor is about to handle a frame (base_observer.py:79).

fn on_push<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _e: &'life1 FramePushEvent<'life2>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

A frame was pushed source→destination (base_observer.py:91).

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

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

The pipeline finished starting (base_observer.py:103).