fix: Stabilize stream most method

Author: k-nasa

src/stream/double_ended_stream/mod.rs

@@ -22,8 +22,6 @@ use try_rfold::TryRFoldFuture;
 /// `Item`s from the back, as well as the front.
 ///
 /// [`Stream`]: trait.Stream.html
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 pub trait DoubleEndedStream: Stream {
     #[doc = r#"
         Attempts to receive the next item from the back of the stream.

src/stream/exact_size_stream.rs

@@ -76,8 +76,6 @@ pub use crate::stream::Stream;
 /// # });
 /// ```
 #[allow(clippy::len_without_is_empty)] // ExactSizeIterator::is_empty is unstable
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 pub trait ExactSizeStream: Stream {
     /// Returns the exact number of times the stream will iterate.
     ///

src/stream/extend.rs

@@ -27,8 +27,6 @@ use crate::stream::IntoStream;
 /// #
 /// # })
 /// ```
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 pub trait Extend<A> {
     /// Extends a collection with the contents of a stream.
     fn extend<'a, T: IntoStream<Item = A> + 'a>(

src/stream/fused_stream.rs

@@ -14,8 +14,6 @@ use crate::stream::Stream;
 /// [`None`]: https://doc.rust-lang.org/std/option/enum.Option.html#variant.None
 /// [`Stream::fuse`]: trait.Stream.html#method.fuse
 /// [`Fuse`]: struct.Fuse.html
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 pub trait FusedStream: Stream {}
 
 impl<S: FusedStream + ?Sized + Unpin> FusedStream for &mut S {}

src/stream/interval.rs

@@ -41,8 +41,6 @@ use futures_timer::Delay;
 /// #
 /// # Ok(()) }) }
 /// ```
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 pub fn interval(dur: Duration) -> Interval {
     Interval {
         delay: Delay::new(dur),
@@ -56,8 +54,6 @@ pub fn interval(dur: Duration) -> Interval {
 /// documentation for more.
 ///
 /// [`interval`]: fn.interval.html
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 #[derive(Debug)]
 pub struct Interval {
     delay: Delay,

src/stream/mod.rs

@@ -300,46 +300,46 @@
 //! [`take`]: trait.Stream.html#method.take
 //! [`min`]: trait.Stream.html#method.min
 
+pub use double_ended_stream::DoubleEndedStream;
 pub use empty::{empty, Empty};
+pub use exact_size_stream::ExactSizeStream;
 pub use from_fn::{from_fn, FromFn};
 pub use from_iter::{from_iter, FromIter};
+pub use fused_stream::FusedStream;
+pub use interval::{interval, Interval};
 pub use once::{once, Once};
+pub use pending::{pending, Pending};
+pub use product::Product;
 pub use repeat::{repeat, Repeat};
 pub use repeat_with::{repeat_with, RepeatWith};
+pub use stream::Merge;
 pub use stream::*;
+pub use successors::{successors, Successors};
+pub use sum::Sum;
 
 pub(crate) mod stream;
 
+mod double_ended_stream;
 mod empty;
+mod exact_size_stream;
 mod from_fn;
 mod from_iter;
+mod fused_stream;
+mod interval;
 mod once;
+mod pending;
+mod product;
 mod repeat;
 mod repeat_with;
+mod successors;
+mod sum;
 
 cfg_unstable! {
-    mod double_ended_stream;
-    mod exact_size_stream;
-    mod extend;
     mod from_stream;
-    mod fused_stream;
-    mod interval;
     mod into_stream;
-    mod pending;
-    mod product;
-    mod successors;
-    mod sum;
+    mod extend;
 
-    pub use double_ended_stream::DoubleEndedStream;
-    pub use exact_size_stream::ExactSizeStream;
     pub use extend::{extend, Extend};
     pub use from_stream::FromStream;
-    pub use fused_stream::FusedStream;
-    pub use interval::{interval, Interval};
     pub use into_stream::IntoStream;
-    pub use pending::{pending, Pending};
-    pub use product::Product;
-    pub use stream::Merge;
-    pub use successors::{successors, Successors};
-    pub use sum::Sum;
 }

src/stream/once.rs

@@ -5,7 +5,6 @@ use pin_project_lite::pin_project;
 use crate::stream::Stream;
 use crate::task::{Context, Poll};
 
-#[cfg(feature = "unstable")]
 use crate::stream::DoubleEndedStream;
 
 /// Creates a stream that yields a single item.
@@ -50,8 +49,7 @@ impl<T> Stream for Once<T> {
     }
 }
 
-#[cfg(feature = "unstable")]
-impl <T> DoubleEndedStream for Once<T> {
+impl<T> DoubleEndedStream for Once<T> {
     fn poll_next_back(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         Poll::Ready(self.project().value.take())
     }

src/stream/product.rs

@@ -1,5 +1,5 @@
-use core::pin::Pin;
 use core::future::Future;
+use core::pin::Pin;
 
 use crate::stream::Stream;
 
@@ -13,8 +13,6 @@ use crate::stream::Stream;
 /// [`product`]: trait.Product.html#tymethod.product
 /// [`FromStream`]: trait.FromStream.html
 /// [`Stream::product`]: trait.Stream.html#method.product
-#[cfg(feature = "unstable")]
-#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
 pub trait Product<A = Self>: Sized {
     /// Method which takes a stream and generates `Self` from the elements by
     /// multiplying the items.
@@ -23,9 +21,9 @@ pub trait Product<A = Self>: Sized {
         S: Stream<Item = A> + 'a;
 }
 
-use core::ops::Mul;
-use core::num::Wrapping;
 use crate::stream::stream::StreamExt;
+use core::num::Wrapping;
+use core::ops::Mul;
 
 macro_rules! integer_product {
     (@impls $one: expr, $($a:ty)*) => ($(
@@ -75,5 +73,5 @@ macro_rules! float_product {
     );
 }
 
-integer_product!{ i8 i16 i32 i64 i128 isize u8 u16 u32 u64 u128 usize }
-float_product!{ f32 f64 }
+integer_product! { i8 i16 i32 i64 i128 isize u8 u16 u32 u64 u128 usize }
+float_product! { f32 f64 }

src/stream/stream/count.rs

@@ -9,8 +9,6 @@ use crate::task::{Context, Poll};
 pin_project! {
     #[doc(hidden)]
     #[allow(missing_debug_implementations)]
-    #[cfg(feature = "unstable")]
-    #[cfg_attr(feature = "docs", doc(cfg(unstable)))]
     pub struct CountFuture<S> {
         #[pin]
         stream: S,

src/stream/stream/merge.rs

@@ -16,8 +16,6 @@ pin_project! {
     ///
     /// [`merge`]: trait.Stream.html#method.merge
     /// [`Stream`]: trait.Stream.html
-    #[cfg(feature = "unstable")]
-    #[cfg_attr(feature = "docs", doc(cfg(unstable)))]
     #[derive(Debug)]
     pub struct Merge<L, R> {
         #[pin]