Struct TurnTrackingObserver 

pub struct TurnTrackingObserver { /* private fields */ }

Tracks user/bot speaking edges → turn boundaries (pipecat TurnTrackingObserver). Records each boundary with its timestamp so tests and exporters can read the turn sequence.

Implementations

impl TurnTrackingObserver

pub fn new() -> Self

pub fn edges(&self) -> Vec<(TurnEdge, i64)>

The recorded turn boundaries (edge, timestamp_ns), in observation order.

Trait Implementations

impl Default for TurnTrackingObserver

fn default() -> Self

Returns the “default value” for a type.

impl FrameObserver for TurnTrackingObserver

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).