Struct StreamUtils 

pub struct StreamUtils;

Stream transformation utilities

Implementations

impl StreamUtils

pub fn map_events<F, T>( stream: EventStream, mapper: F, ) -> Pin<Box<dyn Stream<Item = EventResult<T>> + Send>>

where F: Fn(Box<dyn Event>) -> EventResult<T> + Send + 'static, T: Send + 'static,

Transform a stream of events using a mapping function

pub fn filter_events<F>(stream: EventStream, predicate: F) -> EventStream

where F: Fn(&dyn Event) -> bool + Send + Sync + Clone + 'static,

Filter events based on a predicate

pub fn batch_events(stream: EventStream, batch_size: usize) -> EventBatchStream

Batch events into groups of specified size

pub fn rate_limit( stream: EventStream, rate_limiter: Arc<RateLimiter>, ) -> EventStream

Add rate limiting to an event stream

pub fn deduplicate( stream: EventStream, deduplicator: Arc<EventDeduplicator>, ) -> EventStream

Deduplicate events in a stream