mirror/async-std
2
0
Fork 1
mirror of https://github.com/async-rs/async-std.git synced 2025-02-21 03:39:40 +00:00
Code Issues Releases Wiki Activity

export SkipWhile type

Browse source
This commit is contained in:
Fedor Sakharov 2019-09-21 16:34:51 +03:00
parent f9f97c43c4
commit 93463e8df3
No known key found for this signature in database
GPG key ID: 93D436E666BF0FEE
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -39,6 +39,7 @@ mod zip;
pub use fuse::Fuse; pub use fuse::Fuse;
pub use scan::Scan; pub use scan::Scan;
pub use skip_while::SkipWhile;
pub use take::Take; pub use take::Take;
pub use zip::Zip; pub use zip::Zip;
@ -52,7 +53,6 @@ use fold::FoldFuture;
use min_by::MinByFuture; use min_by::MinByFuture;
use next::NextFuture; use next::NextFuture;
use nth::NthFuture; use nth::NthFuture;
use skip_while::SkipWhile;
use std::cmp::Ordering; use std::cmp::Ordering;
use std::marker::PhantomData; use std::marker::PhantomData;

4
src/stream/stream/skip_while.rs
View file

@ -4,8 +4,8 @@ use std::pin::Pin;
use crate::stream::Stream; use crate::stream::Stream;
use crate::task::{Context, Poll}; use crate::task::{Context, Poll};
#[doc(hidden)] /// A stream to skip elements of another stream based on a predicate.
#[allow(missing_debug_implementations)] #[derive(Debug)]
pub struct SkipWhile<S, P, T> { pub struct SkipWhile<S, P, T> {
stream: S, stream: S,
predicate: Option<P>, predicate: Option<P>,