Module streaming 

Streaming infrastructure for real-time data generation.

This module provides utilities for streaming generation including:

• Channel management for producer-consumer patterns
• Backpressure handling strategies
• Stream coordination and control

Structs

AdaptiveBackpressure

Adaptive backpressure controller that adjusts generation rate.

BackpressureAwareProducer

A rate-aware producer that respects backpressure.

BackpressureMonitor

Monitors and reports backpressure conditions.

BackpressureStats

Statistics about backpressure handling.

BoundedChannel

A bounded channel with configurable backpressure handling.

ChannelStats

Statistics for a streaming channel.

StreamReceiver

Receiver side of a stream event channel.

StreamSender

Sender side of a stream event channel.

Enums

BackpressureState

State of the backpressure system.

Functions

stream_channel

Creates a stream event channel pair.