Module streaming 

Structs

BatchCollector

Batch collector — the default sink. Collects all observations into a Vec.

CountingSink

Counting sink — counts observations by category without storing them. Useful for high-throughput scanning where individual observations are less important than aggregate behavior.

EarlyStopSink

Early-stop sink — halts execution when a predicate matches.

Enums

ControlFlow

Control flow decision returned by the streaming callback.

Traits

ObservationSink

A callback that receives observations during execution.