Struct Filter 

pub struct Filter<S, F> { /* private fields */ }

A VectorDiff stream adapter that presents a filtered view of the underlying ObservableVectors items.

Implementations

impl<S, F> Filter<S, F>

where S: Stream, S::Item: VectorDiffContainer, F: Fn(&VectorDiffContainerStreamElement<S>) -> bool,

pub fn new( values: Vector<VectorDiffContainerStreamElement<S>>, inner: S, filter: F, ) -> (Vector<VectorDiffContainerStreamElement<S>>, Self)

Create a new Filter with the given (unfiltered) initial values, stream of VectorDiff updates for those values, and filter.

Trait Implementations

impl<S, F> Stream for Filter<S, F>

where S: Stream, S::Item: VectorDiffContainer, F: Fn(&VectorDiffContainerStreamElement<S>) -> bool,

type Item = <S as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, S, F> Unpin for Filter<S, F>

where __Origin<'__pin, S, F>: Unpin,