Rate-Limiting Coroutine Streams

Implement flow-control mechanisms to manage backpressure in high-throughput coroutine data pipelines.