mirror/async-std
2
0
Fork 1
mirror of https://github.com/async-rs/async-std.git synced 2025-05-07 23:51:24 +00:00
Code Issues Releases Wiki Activity

mark Stream::count as unstable

Browse source 
Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>
This commit is contained in:
Yoshua Wuyts 2019-11-14 22:45:46 +01:00
parent c58747b5fc
commit 30ff7b09b6
No known key found for this signature in database
GPG key ID: 24EA8164F96777ED
2 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/stream/stream/count.rs
View file

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

6
src/stream/stream/mod.rs
View file

@ -26,7 +26,6 @@ mod any;
mod chain; mod chain;
mod cloned; mod cloned;
mod cmp; mod cmp;
mod count;
mod copied; mod copied;
mod cycle; mod cycle;
mod enumerate; mod enumerate;
@ -69,7 +68,6 @@ mod zip;
use all::AllFuture; use all::AllFuture;
use any::AnyFuture; use any::AnyFuture;
use cmp::CmpFuture; use cmp::CmpFuture;
use count::CountFuture;
use cycle::Cycle; use cycle::Cycle;
use enumerate::Enumerate; use enumerate::Enumerate;
use eq::EqFuture; use eq::EqFuture;
@ -123,12 +121,14 @@ cfg_unstable! {
use crate::stream::into_stream::IntoStream; use crate::stream::into_stream::IntoStream;
use crate::stream::{FromStream, Product, Sum}; use crate::stream::{FromStream, Product, Sum};
use count::CountFuture;
pub use merge::Merge; pub use merge::Merge;
pub use flatten::Flatten; pub use flatten::Flatten;
pub use flat_map::FlatMap; pub use flat_map::FlatMap;
pub use timeout::{TimeoutError, Timeout}; pub use timeout::{TimeoutError, Timeout};
pub use throttle::Throttle; pub use throttle::Throttle;
mod count;
mod merge; mod merge;
mod flatten; mod flatten;
mod flat_map; mod flat_map;
@ -1911,6 +1911,8 @@ extension_trait! {
# }) } # }) }
``` ```
"#] "#]
#[cfg(feature = "unstable")]
#[cfg_attr(feature = "docs", doc(cfg(unstable)))]
fn count(self) -> impl Future<Output = usize> [CountFuture<Self>] fn count(self) -> impl Future<Output = usize> [CountFuture<Self>]
where where
Self: Sized, Self: Sized,