Skip to main content

Module stream_processing

Module stream_processing 

Source
Expand description

Bounded, composable asynchronous data streams and online analytics.

Structsยง

DataStream
Each stage has at most 32 queued values; dropping a consumer stops its producer.
StreamStats