Struct futures_util::stream::FilterMap
source · [−]pub struct FilterMap<St, Fut, F> { /* private fields */ }
Expand description
Stream for the filter_map
method.
Implementations
Acquires a reference to the underlying sink or stream that this combinator is pulling from.
Acquires a mutable reference to the underlying sink or stream that this combinator is pulling from.
Note that care must be taken to avoid tampering with the state of the sink or stream which may otherwise confuse this combinator.
Acquires a pinned mutable reference to the underlying sink or stream that this combinator is pulling from.
Note that care must be taken to avoid tampering with the state of the sink or stream which may otherwise confuse this combinator.
Consumes this combinator, returning the underlying sink or stream.
Note that this may discard intermediate state of this combinator, so care should be taken to avoid losing resources when this is called.
Trait Implementations
impl<St, Fut, F, T> FusedStream for FilterMap<St, Fut, F> where
St: Stream + FusedStream,
F: FnMut1<St::Item, Output = Fut>,
Fut: Future<Output = Option<T>>,
impl<St, Fut, F, T> FusedStream for FilterMap<St, Fut, F> where
St: Stream + FusedStream,
F: FnMut1<St::Item, Output = Fut>,
Fut: Future<Output = Option<T>>,
Returns true
if the stream should no longer be polled.
Auto Trait Implementations
impl<St, Fut, F> RefUnwindSafe for FilterMap<St, Fut, F> where
F: RefUnwindSafe,
Fut: RefUnwindSafe,
St: RefUnwindSafe,
impl<St, Fut, F> UnwindSafe for FilterMap<St, Fut, F> where
F: UnwindSafe,
Fut: UnwindSafe,
St: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Composes a function in front of the sink. Read more
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
Self: Sized,
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
Self: Sized,
Composes a function in front of the sink. Read more
fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::Error) -> E,
Self: Sized,
fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::Error) -> E,
Self: Sized,
Transforms the error returned by the sink.
fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where
Self: Sized,
Self::Error: Into<E>,
fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where
Self: Sized,
Self::Error: Into<E>,
Map this sink’s error to a different error type using the Into
trait. Read more
Adds a fixed-size buffer to the current sink. Read more
Close the sink.
Fanout items to multiple sinks. Read more
Flush the sink, processing all pending items. Read more
A future that completes after the given item has been fully processed into the sink, including flushing. Read more
A future that completes after the given item has been received by the sink. Read more
A future that completes after the given stream has been fully processed into the sink, including flushing. Read more
Wrap this sink in an Either
sink, making it the left-hand variant
of that Either
. Read more
Wrap this stream in an Either
stream, making it the right-hand variant
of that Either
. Read more
A convenience method for calling Sink::poll_ready
on Unpin
sink types. Read more
A convenience method for calling Sink::start_send
on Unpin
sink types. Read more
A convenience method for calling Sink::poll_flush
on Unpin
sink types. Read more