Struct RtviObserver 

pub struct RtviObserver { /* private fields */ }

Pure frame→RTVI-message observer (PROCESSOR-DESIGN §5.1; pipecat RTVIObserver). Plugs into the pipeline Observer fan-out via FrameObserver; for each pushed frame it emits zero or more RtviMessages to the injected RtviSink.

Like pipecat, it observes on the push hook (on_push_frame), processes only the downstream copy of broadcast frames, and de-duplicates by frame id so a frame seen at multiple links is mapped once.

Implementations

impl RtviObserver

pub fn new(sink: Arc<dyn RtviSink>) -> Self

Build an observer that maps frames to sink with default params.

pub fn with_params(sink: Arc<dyn RtviSink>, params: RtviObserverParams) -> Self

Build an observer with explicit RtviObserverParams.

pub fn map_frame(&self, frame: &Frame)

Map one pushed frame to RTVI message(s). Pure (besides the sink + the aggregation state). Exposed for direct unit testing without a pipeline.

Trait Implementations

impl FrameObserver for RtviObserver

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