Make throttle an unstable feature
@@ -60,7 +60,6 @@ mod skip_while;
mod step_by;
mod take;
mod take_while;
-mod throttle;
mod try_fold;
mod try_for_each;
mod zip;
@@ -107,16 +106,15 @@ pub use skip_while::SkipWhile;
pub use step_by::StepBy;
pub use take::Take;
pub use take_while::TakeWhile;
-pub use throttle::Throttle;
pub use zip::Zip;
use std::cmp::Ordering;
use std::marker::PhantomData;
-use std::time::Duration;
cfg_unstable! {
use std::future::Future;
use std::pin::Pin;
+ use std::time::Duration;
use crate::stream::into_stream::IntoStream;
use crate::stream::{FromStream, Product, Sum};
@@ -125,11 +123,13 @@ cfg_unstable! {
pub use flatten::Flatten;
pub use flat_map::FlatMap;
pub use timeout::{TimeoutError, Timeout};
+ pub use throttle::Throttle;
mod merge;
mod flatten;
mod flat_map;
mod timeout;
+ mod throttle;
}
extension_trait! {
@@ -315,6 +315,7 @@ extension_trait! {
TakeWhile::new(self, predicate)
}
+ #[cfg(all(feature = "default", feature = "unstable"))]
#[doc = r#"
Limit the amount of items yielded per timeslice in a stream.
