fn filter<F>(self, predicate: F) -> ParallelFilter<Self, F>
        where Self: Sized,
              F: Send + Fn(&mut Self::Item) -> bool
    {
        ParallelFilter::new(self, predicate)
    }
/// Creates a stream which uses a closure to determine if an element should
/// be emitted. The closure must return true or false. `filter()` creates a
/// stream which calls this closure on each element. If the closure returns
/// true, then the element is returned. If the closure returns false, it
/// will try again, and call the closure on the next element, seeing if it
/// passes the test.
///
/// # Examples
///
/// ```
/// use asyncplify::*;
/// use asyncplify::schedulers::*;
///
/// (0..4)
///     .into_stream()
///     .observe_on_parallel(EventLoop::new())
///     .filter(|v| *v > 2)
///     .subscribe_action(|v| assert!(v == 3, "v = {:?}", v))
///
/// ```
Creates a stream which uses a closure to determine if an element should
be emitted. The closure must return true or false. `filter()` creates a
stream which calls this closure on each element. If the closure returns
true, then the element is returned. If the closure returns false, it
will try again, and call the closure on the next element, seeing if it
passes the test.
Creates a stream which uses a closure to determine if an element should be emitted . The closure must return true or false . ` filter () ` creates a stream which calls this closure on each element . If the closure returns true then the element is returned . If the closure returns false it will try again and call the closure on the next element seeing if it passes the test .
fn filter<F>(self, predicate: F) -> ParallelFilter<Self, F>
        where Self: Sized,
              F: Send + Fn(&mut Self::Item) -> bool
    {
        ParallelFilter::new(self, predicate)
    }
fn filter < F > ( self , predicate : F ) -> ParallelFilter < Self , F > where Self : Sized , F : Send + Fn ( & mut Self :: Item ) -> bool { ParallelFilter :: new ( self , predicate ) }
Creates a stream which uses a closure to determine if an element should
be emitted.
Creates a stream which uses a closure to determine if an element should be emitted .
self
predicate
F
self
predicate
F
examples
```
use asyncplify::*;
use asyncplify::schedulers::*.




` ` ` use asyncplify :: * ; use asyncplify :: schedulers :: * .