Struct futures_util::stream::FlatMapUnordered
source · [−]pub struct FlatMapUnordered<St, U, F>where
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,{ /* private fields */ }
Expand description
Stream for the flat_map_unordered
method.
Implementations
sourceimpl<St, U, F> FlatMapUnordered<St, U, F>where
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,
impl<St, U, F> FlatMapUnordered<St, U, F>where
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,
sourcepub fn get_ref(&self) -> &St
pub fn get_ref(&self) -> &St
Acquires a reference to the underlying sink or stream that this combinator is pulling from.
sourcepub fn get_mut(&mut self) -> &mut St
pub fn get_mut(&mut self) -> &mut St
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.
sourcepub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut St>
pub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut St>
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.
sourcepub fn into_inner(self) -> St
pub fn into_inner(self) -> St
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
sourceimpl<St, U, F> Debug for FlatMapUnordered<St, U, F>where
FlattenUnordered<Map<St, F>>: Debug,
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,
impl<St, U, F> Debug for FlatMapUnordered<St, U, F>where
FlattenUnordered<Map<St, F>>: Debug,
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,
sourceimpl<St, U, F> FusedStream for FlatMapUnordered<St, U, F>where
FlattenUnordered<Map<St, F>>: FusedStream,
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,
impl<St, U, F> FusedStream for FlatMapUnordered<St, U, F>where
FlattenUnordered<Map<St, F>>: FusedStream,
St: Stream,
U: Stream,
U: Unpin,
F: FnMut(St::Item) -> U,
sourcefn is_terminated(&self) -> bool
fn is_terminated(&self) -> bool
true
if the stream should no longer be polled.