Struct logid::evident::publisher::EvidentPublisher

pub struct EvidentPublisher<K, M, T, F>where
    K: Id + CaptureControl,
    M: Msg,
    T: EventEntry<K, M>,
    F: Filter<K, M>,{ /* private fields */ }

Implementations

impl<K, M, T, F> EvidentPublisher<K, M, T, F>where K: Id + CaptureControl, M: Msg, T: EventEntry<K, M>, F: Filter<K, M>,

pub fn new( on_event: impl FnMut(Event<K, M, T>) + Send + 'static, capture_mode: CaptureMode, capture_channel_bound: usize, subscription_channel_bound: usize, time_stamp_kind: EventTimestampKind ) -> EvidentPublisher<K, M, T, F>

pub fn with( on_event: impl FnMut(Event<K, M, T>) + Send + 'static, filter: F, capture_mode: CaptureMode, capture_channel_bound: usize, subscription_channel_bound: usize, timestamp_kind: EventTimestampKind ) -> EvidentPublisher<K, M, T, F>

pub fn get_filter(&self) -> &Option<F>

pub fn entry_allowed(&self, entry: &impl EventEntry<K, M>) -> bool

pub fn _capture<I>(&self, interm_event: &mut I)where I: IntermediaryEvent<K, M, T>,

pub fn get_capture_mode(&self) -> CaptureMode

pub fn set_capture_mode(&self, mode: CaptureMode)

pub fn get_missed_captures(&self) -> usize

pub fn reset_missed_captures(&self)

pub fn subscribe( &self, id: K ) -> Result<Subscription<'_, K, M, T, F>, SubscriptionError<K>>

pub fn subscribe_to_many( &self, ids: Vec<K, Global> ) -> Result<Subscription<'_, K, M, T, F>, SubscriptionError<K>>

pub fn subscribe_to_all_events( &self ) -> Result<Subscription<'_, K, M, T, F>, SubscriptionError<K>>

pub fn is_capturing(&self) -> bool

pub fn start(&self)

pub fn stop(&self)

pub fn on_event(&self, event: Event<K, M, T>)