Struct EventStream 

pub struct EventStream { /* private fields */ }

A stream of events with processing capabilities.

Implementations

impl EventStream

pub fn new() -> Self

Create a new event stream.

pub fn with_max_size(max_size: usize) -> Self

Create a stream with a maximum size.

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

Push an event to the stream.

pub fn pop(&mut self) -> Option<Event>

Pop the next event from the stream.

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

Peek at the next event.

pub fn len(&self) -> usize

Get the number of events in the stream.

pub fn is_empty(&self) -> bool

Check if the stream is empty.

pub fn clear(&mut self)

Clear all events.

pub fn filter(&self, filter: &EventFilter) -> Vec<&Event>

Filter events in the stream.

pub fn take(&mut self, filter: &EventFilter) -> Vec<Event>

Take events matching a filter.

pub fn as_slice(&self) -> impl Iterator<Item = &Event>

Get events as a slice.

Trait Implementations

impl Default for EventStream

fn default() -> Self

Returns the “default value” for a type.