Struct ordered_stream::Peekable
source · pub struct Peekable<S: OrderedStream> { /* private fields */ }
Expand description
A stream for the peekable
function.
Implementations§
source§impl<S: OrderedStream> Peekable<S>
impl<S: OrderedStream> Peekable<S>
sourcepub fn into_inner(self) -> (S, Option<(S::Data, S::Ordering)>)
pub fn into_inner(self) -> (S, Option<(S::Data, S::Ordering)>)
Convert into the source stream.
This method returns the source stream along with any buffered item and its ordering.
sourcepub fn poll_peek_before(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
before: Option<&S::Ordering>,
) -> Poll<PollResult<&S::Ordering, &mut S::Data>>
pub fn poll_peek_before( self: Pin<&mut Self>, cx: &mut Context<'_>, before: Option<&S::Ordering>, ) -> Poll<PollResult<&S::Ordering, &mut S::Data>>
Peek on the next item in the stream
Trait Implementations§
source§impl<S: OrderedStream> FusedOrderedStream for Peekable<S>
impl<S: OrderedStream> FusedOrderedStream for Peekable<S>
source§fn is_terminated(&self) -> bool
fn is_terminated(&self) -> bool
Returns
true
if the stream should no longer be polled.source§impl<S: OrderedStream> OrderedStream for Peekable<S>
impl<S: OrderedStream> OrderedStream for Peekable<S>
source§fn poll_next_before(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
before: Option<&S::Ordering>,
) -> Poll<PollResult<S::Ordering, S::Data>>
fn poll_next_before( self: Pin<&mut Self>, cx: &mut Context<'_>, before: Option<&S::Ordering>, ) -> Poll<PollResult<S::Ordering, S::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 moresource§fn 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: OrderedStream> Unpin for Peekable<S>where
PinnedFieldsOf<__Origin<'__pin, S>>: Unpin,
Auto Trait Implementations§
impl<S> Freeze for Peekable<S>
impl<S> RefUnwindSafe for Peekable<S>where
S: RefUnwindSafe,
<S as OrderedStream>::Ordering: RefUnwindSafe,
<S as OrderedStream>::Data: RefUnwindSafe,
impl<S> Send for Peekable<S>
impl<S> Sync for Peekable<S>
impl<S> UnwindSafe for Peekable<S>where
S: UnwindSafe,
<S as OrderedStream>::Ordering: UnwindSafe,
<S as OrderedStream>::Data: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> OrderedStreamExt for Twhere
T: OrderedStream + ?Sized,
impl<T> OrderedStreamExt for Twhere
T: OrderedStream + ?Sized,
source§fn map_item<F, R>(self, f: F) -> MapItem<Self, F>
fn map_item<F, R>(self, f: F) -> MapItem<Self, F>
Apply a closure to the items that has access to the ordering data.
source§fn map_ordering<NewOrdering, NewData, MapInto, MapFrom>(
self,
map_into: MapInto,
map_from: MapFrom,
) -> MapOrdering<Self, MapInto, MapFrom>where
Self: Sized,
MapInto: FnMut(Self::Ordering, Self::Data) -> (NewOrdering, NewData),
MapFrom: FnMut(&NewOrdering) -> Option<Self::Ordering>,
NewOrdering: Ord,
fn map_ordering<NewOrdering, NewData, MapInto, MapFrom>(
self,
map_into: MapInto,
map_from: MapFrom,
) -> MapOrdering<Self, MapInto, MapFrom>where
Self: Sized,
MapInto: FnMut(Self::Ordering, Self::Data) -> (NewOrdering, NewData),
MapFrom: FnMut(&NewOrdering) -> Option<Self::Ordering>,
NewOrdering: Ord,
Apply a closure to the items that can change the type of the ordering value. Read more
fn filter<F>(self, filter: F) -> Filter<Self, F>
fn filter_map<F, R>(self, filter: F) -> FilterMap<Self, F>
source§fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
Convert this into a
Stream
, discarding the ordering information.source§fn into_tuple_stream(self) -> IntoTupleStream<Self>where
Self: Sized,
fn into_tuple_stream(self) -> IntoTupleStream<Self>where
Self: Sized,
Convert this into a
Stream
, keeping the ordering objects.source§fn into_ordering(self) -> IntoOrdering<Self>where
Self: Sized,
fn into_ordering(self) -> IntoOrdering<Self>where
Self: Sized,
Convert this into a
Stream
, keeping only the ordering objects.source§fn next_before<'a>(
&'a mut self,
before: Option<&'a Self::Ordering>,
) -> NextBefore<'a, Self> ⓘwhere
Self: Unpin,
fn next_before<'a>(
&'a mut self,
before: Option<&'a Self::Ordering>,
) -> NextBefore<'a, Self> ⓘwhere
Self: Unpin,
Return a
PollResult
corresponding to the next item in the stream.