Struct Observer 

pub struct Observer(/* private fields */);

Cheap clonable fan-out over many observers (pipecat TaskObserver proxy, task.py:401). When empty, the run loop never calls into it.

Implementations

impl Observer

pub fn new(observers: Vec<Arc<dyn FrameObserver>>) -> Self

Build a fan-out over observers.

pub fn is_empty(&self) -> bool

Whether any observer is registered (the run loop checks this to stay zero-cost when off — though it also Option-gates the whole Observer).

pub async fn on_process(&self, e: &FrameEvent<'_>)

Fan on_process out to every observer.

pub async fn on_push(&self, e: &FramePushEvent<'_>)

Fan on_push out to every observer.

pub async fn on_pipeline_started(&self)

Fan on_pipeline_started out to every observer.

Trait Implementations

impl Clone for Observer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Observer

fn default() -> Self

Returns the “default value” for a type.