Trait par_stream::prelude::FallibleIndexedStreamExt [−][src]
pub trait FallibleIndexedStreamExt where
Self: TryStream, {
fn try_enumerate<T, E>(self) -> TryEnumerate<Self, T, E>
where
Self: Stream<Item = Result<T, E>>;
fn try_wrapping_enumerate<T, E>(self) -> TryWrappingEnumerate<Self, T, E>
where
Self: Stream<Item = Result<T, E>>;
fn try_reorder_enumerated<T, E>(self) -> TryReorderEnumerated<Self, T, E>
where
Self: Stream<Item = Result<(usize, T), E>>;
}Expand description
An extension trait that controls ordering of items of fallible streams.
Required methods
fn try_enumerate<T, E>(self) -> TryEnumerate<Self, T, E> where
Self: Stream<Item = Result<T, E>>,
fn try_enumerate<T, E>(self) -> TryEnumerate<Self, T, E> where
Self: Stream<Item = Result<T, E>>,
Create a fallible stream that gives the current iteration count.
The count wraps to zero if the count overflows.
fn try_wrapping_enumerate<T, E>(self) -> TryWrappingEnumerate<Self, T, E> where
Self: Stream<Item = Result<T, E>>,
fn try_wrapping_enumerate<T, E>(self) -> TryWrappingEnumerate<Self, T, E> where
Self: Stream<Item = Result<T, E>>,
Create a fallible stream that gives the current iteration count.
The count wraps to zero if the count overflows.
fn try_reorder_enumerated<T, E>(self) -> TryReorderEnumerated<Self, T, E> where
Self: Stream<Item = Result<(usize, T), E>>,
fn try_reorder_enumerated<T, E>(self) -> TryReorderEnumerated<Self, T, E> where
Self: Stream<Item = Result<(usize, T), E>>,
Creates a fallible stream that reorders the items according to the iteration count.
It is usually combined with try_wrapping_enumerate.