stream_throttle 0.5.1

Provides a Stream combinator, to limit the rate at which items are produced.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::time::Duration;

/// Defines the the throttle rate.
///
/// e.g. 3 items per-second.
#[derive(Copy, Clone, Debug)]
pub struct ThrottleRate {
	count: usize,
	duration: Duration,
}

impl ThrottleRate {
	pub fn new(count: usize, duration: Duration) -> Self {
		assert!(count > 0);
		assert!(duration > Duration::from_millis(0));

		Self { count, duration }
	}

	pub fn count(&self) -> usize {
		self.count
	}

	pub fn duration(&self) -> Duration {
		self.duration
	}
}