Module stream 

Aegis Streaming Stream Processing

Stream processing utilities for event transformation.

@version 0.1.0 @author AutomataNexus Development Team

Structs

EventStream

A stream of events with processing capabilities.

StreamProcessor

Processes events in a stream.

Window

A time window of events.

WindowedStream

A time-windowed event stream.

Enums

AggregateFunction

Aggregate function for stream processing.

Traits

ProcessingStep

A step in the processing pipeline.