Struct ZeroCopyEventStream 

pub struct ZeroCopyEventStream { /* private fields */ }

Zero-copy event streaming buffer

Implementations

impl ZeroCopyEventStream

pub fn new(capacity: usize) -> Self

Create new event stream with given capacity

pub fn push_events(&mut self, new_events: Vec<EventMessage>)

Push events efficiently by moving data

pub fn drain_batch(&mut self, size: usize) -> Vec<EventMessage>

Drain a batch of events efficiently

pub fn len(&self) -> usize

Get current number of events

pub fn is_empty(&self) -> bool

Check if empty

pub fn peek_events(&self, count: usize) -> Vec<&EventMessage>

Get events without removing them