Struct ordered_stream::Filter
source · [−]pub struct Filter<S, F> { /* private fields */ }Expand description
A stream for the filter function.
Trait Implementations
sourceimpl<S, F> OrderedStream for Filter<S, F> where
S: OrderedStream,
F: FnMut(&S::Data) -> bool,
impl<S, F> OrderedStream for Filter<S, F> where
S: OrderedStream,
F: FnMut(&S::Data) -> bool,
type Data = <S as OrderedStream>::Data
type Data = <S as OrderedStream>::Data
The unordered data carried by this stream Read more
type Ordering = <S as OrderedStream>::Ordering
type Ordering = <S as OrderedStream>::Ordering
The type ordered by this stream. Read more
sourcefn poll_next_before(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
before: Option<&Self::Ordering>
) -> Poll<PollResult<Self::Ordering, Self::Data>>
fn poll_next_before(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
before: Option<&Self::Ordering>
) -> Poll<PollResult<Self::Ordering, Self::Data>>
Attempt to pull out the next value of this stream, registering the current task for wakeup
if needed, and returning NoneBefore if it is known that the stream will not produce any
more values ordered before the given point. Read more
sourcefn position_hint(&self) -> Option<MaybeBorrowed<'_, Self::Ordering>>
fn position_hint(&self) -> Option<MaybeBorrowed<'_, Self::Ordering>>
The minimum value of the ordering for any future items. Read more
impl<'__pin, S, F> Unpin for Filter<S, F> where
__Origin<'__pin, S, F>: Unpin,
Auto Trait Implementations
impl<S, F> RefUnwindSafe for Filter<S, F> where
F: RefUnwindSafe,
S: RefUnwindSafe,
impl<S, F> Send for Filter<S, F> where
F: Send,
S: Send,
impl<S, F> Sync for Filter<S, F> where
F: Sync,
S: Sync,
impl<S, F> UnwindSafe for Filter<S, F> where
F: UnwindSafe,
S: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more