forked from mirror/async-std
export Filter type
This commit is contained in:
parent
e7ae10ebee
commit
e430851bc4
2 changed files with 3 additions and 3 deletions
|
@ -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 filter elements of another stream with a predicate.
|
||||||
#[allow(missing_debug_implementations)]
|
#[derive(Debug)]
|
||||||
pub struct Filter<S, P, T> {
|
pub struct Filter<S, P, T> {
|
||||||
stream: S,
|
stream: S,
|
||||||
predicate: P,
|
predicate: P,
|
||||||
|
|
|
@ -37,6 +37,7 @@ mod scan;
|
||||||
mod take;
|
mod take;
|
||||||
mod zip;
|
mod zip;
|
||||||
|
|
||||||
|
pub use filter::Filter;
|
||||||
pub use fuse::Fuse;
|
pub use fuse::Fuse;
|
||||||
pub use scan::Scan;
|
pub use scan::Scan;
|
||||||
pub use take::Take;
|
pub use take::Take;
|
||||||
|
@ -45,7 +46,6 @@ pub use zip::Zip;
|
||||||
use all::AllFuture;
|
use all::AllFuture;
|
||||||
use any::AnyFuture;
|
use any::AnyFuture;
|
||||||
use enumerate::Enumerate;
|
use enumerate::Enumerate;
|
||||||
use filter::Filter;
|
|
||||||
use filter_map::FilterMap;
|
use filter_map::FilterMap;
|
||||||
use find::FindFuture;
|
use find::FindFuture;
|
||||||
use find_map::FindMapFuture;
|
use find_map::FindMapFuture;
|
||||||
|
|
Loading…
Reference in a new issue