Module operators 

Advanced Stream Operators

This module provides functional stream processing operators:

• map: Transform events
• filter: Select events based on predicate
• flatMap: Transform and flatten events
• partition: Split streams based on criteria
• reduce: Aggregate events
• scan: Stateful transformation
• distinct: Remove duplicates
• throttle: Rate limiting
• debounce: Event coalescing

Structs

DebounceOperator

Debounce operator - event coalescing

DistinctOperator

Distinct operator - removes duplicate events

FilterOperator

Filter operator - selects events based on predicate

FlatMapOperator

FlatMap operator - transforms and flattens events

MapOperator

Map operator - transforms each event

OperatorPipeline

Stream operator pipeline for chaining operations

OperatorStats

Operator statistics for monitoring

PartitionOperator

Partition operator - splits stream into multiple partitions

PipelineBuilder

Builder for creating operator pipelines fluently

PipelineStats

ReduceOperator

Reduce operator - stateful aggregation

ThrottleOperator

Throttle operator - rate limiting

Traits

StreamOperator

Stream operator trait for composable transformations