Struct FanoutFlowEventObserver 

pub struct FanoutFlowEventObserver { /* private fields */ }

Observer that forwards every committed event to multiple observers.

Implementations

impl FanoutFlowEventObserver

pub fn new() -> Self

pub fn from_observers(observers: Vec<Arc<dyn FlowEventObserver>>) -> Self

pub fn with_observer<O>(self, observer: Arc<O>) -> Self

where O: FlowEventObserver + 'static,

pub fn with_dyn_observer(self, observer: Arc<dyn FlowEventObserver>) -> Self

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for FanoutFlowEventObserver

fn clone(&self) -> FanoutFlowEventObserver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanoutFlowEventObserver

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FanoutFlowEventObserver

fn default() -> FanoutFlowEventObserver

Returns the “default value” for a type.

impl FlowEventObserver for FanoutFlowEventObserver

fn observe<'life0, 'async_trait>( &'life0 self, envelope: FlowEventEnvelope, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,