Struct EventObserverChannel 

pub struct EventObserverChannel { /* private fields */ }

Observer implementation that sends observed event contexts to a channel.

Use event_observer_channel when the publish path should only enqueue telemetry and another thread or task will do slower export work. Sending to the channel is best-effort: if the receiver has been dropped, publication still succeeds and the context is discarded.

Implementations

impl EventObserverChannel

pub fn new(sender: Sender<ObservedEventContext>) -> Self

Creates a channel observer from an existing sender.

Trait Implementations

impl Clone for EventObserverChannel

fn clone(&self) -> EventObserverChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> EventObserver<T> for EventObserverChannel

where T: Clone + Send + Sync + 'static,

fn on_event_published(&self, context: &ObservedEventContext)

Called after an event is published.