pub struct IntoTupleStream<S> { /* private fields */ }
Expand description
A Stream
for the into_tuple_stream
function.
Trait Implementations§
Source§impl<S> Debug for IntoTupleStream<S>where
S: Debug,
impl<S> Debug for IntoTupleStream<S>where
S: Debug,
Source§impl<S> FusedStream for IntoTupleStream<S>where
S: FusedOrderedStream,
impl<S> FusedStream for IntoTupleStream<S>where
S: FusedOrderedStream,
Source§fn is_terminated(&self) -> bool
fn is_terminated(&self) -> bool
Returns
true
if the stream should no longer be polled.Source§impl<S> Stream for IntoTupleStream<S>where
S: OrderedStream,
impl<S> Stream for IntoTupleStream<S>where
S: OrderedStream,
Source§type Item = (<S as OrderedStream>::Ordering, <S as OrderedStream>::Data)
type Item = (<S as OrderedStream>::Ordering, <S as OrderedStream>::Data)
Values yielded by the stream.
Source§fn poll_next(
self: Pin<&mut IntoTupleStream<S>>,
cx: &mut Context<'_>,
) -> Poll<Option<<IntoTupleStream<S> as Stream>::Item>>
fn poll_next( self: Pin<&mut IntoTupleStream<S>>, cx: &mut Context<'_>, ) -> Poll<Option<<IntoTupleStream<S> as Stream>::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. Read moreimpl<'__pin, S> Unpin for IntoTupleStream<S>where
<PinnedFieldsOfHelperStruct<__Origin<'__pin, S>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,
Auto Trait Implementations§
impl<S> Freeze for IntoTupleStream<S>where
S: Freeze,
impl<S> RefUnwindSafe for IntoTupleStream<S>where
S: RefUnwindSafe,
impl<S> Send for IntoTupleStream<S>where
S: Send,
impl<S> Sync for IntoTupleStream<S>where
S: Sync,
impl<S> UnwindSafe for IntoTupleStream<S>where
S: 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