Struct ordered_stream::MapItem
source · [−]pub struct MapItem<S, F> { /* private fields */ }Expand description
A stream for the map_item function.
Trait Implementations
sourceimpl<S, F, R> OrderedStream for MapItem<S, F> where
S: OrderedStream,
F: FnMut(&S::Ordering, S::Data) -> R,
impl<S, F, R> OrderedStream for MapItem<S, F> where
S: OrderedStream,
F: FnMut(&S::Ordering, S::Data) -> R,
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 MapItem<S, F> where
__Origin<'__pin, S, F>: Unpin,
Auto Trait Implementations
impl<S, F> RefUnwindSafe for MapItem<S, F> where
F: RefUnwindSafe,
S: RefUnwindSafe,
impl<S, F> Send for MapItem<S, F> where
F: Send,
S: Send,
impl<S, F> Sync for MapItem<S, F> where
F: Sync,
S: Sync,
impl<S, F> UnwindSafe for MapItem<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