Struct StreamingEventQueue 

pub struct StreamingEventQueue {
    pub events: VecDeque<StreamingEvent>,
    pub max_events: usize,
    pub total_events_enqueued: u64,
    pub total_events_dequeued: u64,
}

Fields

events: VecDeque<StreamingEvent>

max_events: usize

total_events_enqueued: u64

total_events_dequeued: u64

Implementations

impl StreamingEventQueue

pub fn new(max_events: usize) -> Self

pub fn push(&mut self, event: StreamingEvent)

pub fn drain(&mut self) -> Vec<StreamingEvent>

pub fn peek(&self) -> Option<&StreamingEvent>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn count_by_type(&self, discriminant: &str) -> usize

Trait Implementations

impl Clone for StreamingEventQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingEventQueue

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

Formats the value using the given formatter.