stream_throttle

Provides a Rust Stream combinator, to limit the rate at which items are produced.

Key Features

• Throttling is implemented via poll(), and not via any sort of buffering.
• The throttling behaviour can be applied to both Stream's and Future's.
• Multiple streams/futures can be throttled together as a group.

Example throttling of Stream

```rust let rate = ThrottleRate::new(5, Duration::new(2, 0)); let pool = ThrottlePool::new(rate);

let work = stream::repeat(()) .throttle(pool) .foreach(|| Ok(()));

tokio::run(work); ```

Example throttling of Future

```rust let rate = ThrottleRate::new(5, Duration::new(2, 0)); let pool = ThrottlePool::new(rate);

pool.queue() .then(|_| Ok(()));

tokio::run(work); ```