Struct IdleFrameObserver 

pub struct IdleFrameObserver { /* private fields */ }

Drives idle detection (PROCESSOR-DESIGN §4.1 / pipecat task.py:70): bumps a monotonic counter every time one of the configured “activity” frame kinds is observed. The PipelineTask idle watcher reads the counter and fires a timeout when it stops advancing.

Implementations

impl IdleFrameObserver

pub fn new(activity: Vec<FrameKind>) -> Self

Observe activity frame kinds as “not idle” signals.

pub fn activity_count(&self) -> u64

The current activity counter (advances on each observed activity frame).

Trait Implementations

impl FrameObserver for IdleFrameObserver

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