pub struct Never(/* private fields */);Trait Implementations§
Source§impl<'de> Deserialize<'de> for Never
impl<'de> Deserialize<'de> for Never
Source§fn deserialize<D>(_deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
fn deserialize<D>(_deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl DistributedStream for Never
impl DistributedStream for Never
type Item = Never
type Task = Never
fn size_hint(&self) -> (usize, Option<usize>)
fn next_task( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Option<Self::Task>>
fn reduce<'life0, 'async_trait, P, B, R1, R2, R3>(
self,
pool: &'life0 P,
reduce_a: R1,
reduce_b: R2,
reduce_c: R3,
) -> Pin<Box<dyn Future<Output = B> + 'async_trait>>where
P: ProcessPool + 'async_trait,
R1: ReducerSend<Self::Item> + Clone + ProcessSend + 'static + 'async_trait,
R2: ReducerProcessSend<<R1 as ReducerSend<Self::Item>>::Done> + Clone + ProcessSend + 'static + 'async_trait,
R3: Reducer<<R2 as ReducerProcessSend<<R1 as ReducerSend<Self::Item>>::Done>>::Done, Done = B> + 'async_trait,
Self::Task: 'static,
Self: Sized + 'async_trait,
B: 'async_trait,
'life0: 'async_trait,
fn pipe<'life0, 'async_trait, P, DistSink, A>(
self,
pool: &'life0 P,
sink: DistSink,
) -> Pin<Box<dyn Future<Output = A> + 'async_trait>>where
P: ProcessPool + 'async_trait,
DistSink: DistributedSink<Self::Item, Done = A> + 'async_trait,
<DistSink::Pipe as DistributedPipe<Self::Item>>::Task: 'static,
DistSink::ReduceA: 'static,
DistSink::ReduceB: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
A: 'async_trait,
'life0: 'async_trait,
fn fork<'life0, 'async_trait, P, DistSinkA, DistSinkB, A, B>(
self,
pool: &'life0 P,
sink_a: DistSinkA,
sink_b: DistSinkB,
) -> Pin<Box<dyn Future<Output = (A, B)> + 'async_trait>>where
P: ProcessPool + 'async_trait,
DistSinkA: DistributedSink<Self::Item, Done = A> + 'async_trait,
DistSinkB: for<'a> DistributedSink<&'a Self::Item, Done = B> + 'static + 'async_trait,
<DistSinkA::Pipe as DistributedPipe<Self::Item>>::Task: 'static,
DistSinkA::ReduceA: 'static,
DistSinkA::ReduceB: 'static,
<DistSinkB as DistributedSink<&'static Self::Item>>::ReduceA: 'static,
<DistSinkB as DistributedSink<&'static Self::Item>>::ReduceB: 'static,
<<DistSinkB as DistributedSink<&'static Self::Item>>::Pipe as DistributedPipe<&'static Self::Item>>::Task: 'static,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
A: 'async_trait,
B: 'async_trait,
'life0: 'async_trait,
fn group_by<'life0, 'async_trait, P, S, A, B>(
self,
pool: &'life0 P,
sink: S,
) -> Pin<Box<dyn Future<Output = IndexMap<A, S::Done>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
A: Eq + Hash + ProcessSend + 'static + 'async_trait,
B: 'static + 'async_trait,
S: DistributedSink<B> + 'async_trait,
<S::Pipe as DistributedPipe<B>>::Task: Clone + ProcessSend + 'static,
S::ReduceA: 'static,
S::ReduceB: 'static,
S::ReduceC: Clone,
S::Done: ProcessSend + 'static,
Self::Task: 'static,
Self: DistributedStream<Item = (A, B)> + Sized + 'async_trait,
'life0: 'async_trait,
fn collect<'life0, 'async_trait, P, B>(
self,
pool: &'life0 P,
) -> Pin<Box<dyn Future<Output = B> + 'async_trait>>where
P: ProcessPool + 'async_trait,
B: FromDistributedStream<Self::Item> + 'async_trait,
B::ReduceA: ProcessSend + 'static,
B::ReduceB: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn inspect<F>(self, f: F) -> Inspect<Self, F>
fn update<F>(self, f: F) -> Update<Self, F>
fn map<B, F>(self, f: F) -> Map<Self, F>
fn flat_map<B, F>(self, f: F) -> FlatMap<Self, F>
fn filter<F>(self, f: F) -> Filter<Self, F>
fn left_join<K, V1, V2>(
self,
right: impl IntoIterator<Item = (K, V2)>,
) -> LeftJoin<Self, K, V1, V2>where
K: Eq + Hash + Clone + ProcessSend + 'static,
V1: 'static,
V2: Clone + ProcessSend + 'static,
Self: DistributedStream<Item = (K, V1)> + Sized,
fn inner_join<K, V1, V2>(
self,
right: impl IntoIterator<Item = (K, V2)>,
) -> InnerJoin<Self, K, V1, V2>where
K: Eq + Hash + Clone + ProcessSend + 'static,
V1: 'static,
V2: Clone + ProcessSend + 'static,
Self: DistributedStream<Item = (K, V1)> + Sized,
fn chain<C>(self, chain: C) -> Chain<Self, C::DistStream>
fn for_each<'life0, 'async_trait, P, F>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = ()> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(Self::Item) + Clone + ProcessSend + 'static + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn fold<'life0, 'async_trait, P, ID, F, B>(
self,
pool: &'life0 P,
identity: ID,
op: F,
) -> Pin<Box<dyn Future<Output = B> + 'async_trait>>where
P: ProcessPool + 'async_trait,
ID: FnMut() -> B + Clone + ProcessSend + 'static + 'async_trait,
F: FnMut(B, Either<Self::Item, B>) -> B + Clone + ProcessSend + 'static + 'async_trait,
B: ProcessSend + 'static + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn count<'life0, 'async_trait, P>(
self,
pool: &'life0 P,
) -> Pin<Box<dyn Future<Output = usize> + 'async_trait>>where
P: ProcessPool + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn sum<'life0, 'async_trait, P, S>(
self,
pool: &'life0 P,
) -> Pin<Box<dyn Future<Output = S> + 'async_trait>>where
P: ProcessPool + 'async_trait,
S: Sum<Self::Item> + Sum<S> + ProcessSend + 'static + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn combine<'life0, 'async_trait, P, F>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(Self::Item, Self::Item) -> Self::Item + Clone + ProcessSend + 'static + 'async_trait,
Self::Item: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn max_by<'life0, 'async_trait, P, F>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(&Self::Item, &Self::Item) -> Ordering + Clone + ProcessSend + 'static + 'async_trait,
Self::Item: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn max_by_key<'life0, 'async_trait, P, F, B>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(&Self::Item) -> B + Clone + ProcessSend + 'static + 'async_trait,
B: Ord + 'static + 'async_trait,
Self::Item: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn min_by<'life0, 'async_trait, P, F>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(&Self::Item, &Self::Item) -> Ordering + Clone + ProcessSend + 'static + 'async_trait,
Self::Item: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn min_by_key<'life0, 'async_trait, P, F, B>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(&Self::Item) -> B + Clone + ProcessSend + 'static + 'async_trait,
B: Ord + 'static + 'async_trait,
Self::Item: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn most_distinct<'life0, 'async_trait, P, A, B>(
self,
pool: &'life0 P,
n: usize,
probability: f64,
tolerance: f64,
error_rate: f64,
) -> Pin<Box<dyn Future<Output = Top<A, HyperLogLogMagnitude<B>>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
Self: DistributedStream<Item = (A, B)> + Sized + 'async_trait,
A: Hash + Eq + Clone + ProcessSend + 'static + 'async_trait,
B: Hash + 'static + 'async_trait,
Self::Task: 'static,
'life0: 'async_trait,
fn sample_unstable<'life0, 'async_trait, P>(
self,
pool: &'life0 P,
samples: usize,
) -> Pin<Box<dyn Future<Output = SampleUnstable<Self::Item>> + 'async_trait>>where
P: ProcessPool + 'async_trait,
Self::Item: ProcessSend + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn all<'life0, 'async_trait, P, F>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = bool> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(Self::Item) -> bool + Clone + ProcessSend + 'static + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn any<'life0, 'async_trait, P, F>(
self,
pool: &'life0 P,
f: F,
) -> Pin<Box<dyn Future<Output = bool> + 'async_trait>>where
P: ProcessPool + 'async_trait,
F: FnMut(Self::Item) -> bool + Clone + ProcessSend + 'static + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
Source§impl ParallelStream for Never
impl ParallelStream for Never
type Item = Never
type Task = Never
fn size_hint(&self) -> (usize, Option<usize>)
fn next_task( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Option<Self::Task>>
fn reduce<'life0, 'async_trait, P, B, R1, R3>(
self,
pool: &'life0 P,
reduce_a: R1,
reduce_c: R3,
) -> Pin<Box<dyn Future<Output = B> + 'async_trait>>where
P: ThreadPool + 'async_trait,
R1: ReducerSend<Self::Item> + Clone + Send + 'static + 'async_trait,
R3: Reducer<<R1 as ReducerSend<Self::Item>>::Done, Done = B> + 'async_trait,
Self::Task: 'static,
Self: Sized + 'async_trait,
B: 'async_trait,
'life0: 'async_trait,
fn pipe<'life0, 'async_trait, P, ParSink, A>(
self,
pool: &'life0 P,
sink: ParSink,
) -> Pin<Box<dyn Future<Output = A> + 'async_trait>>where
P: ThreadPool + 'async_trait,
ParSink: ParallelSink<Self::Item, Done = A> + 'async_trait,
<ParSink::Pipe as ParallelPipe<Self::Item>>::Task: 'static,
ParSink::ReduceA: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
A: 'async_trait,
'life0: 'async_trait,
fn fork<'life0, 'async_trait, P, ParSinkA, ParSinkB, A, B>(
self,
pool: &'life0 P,
sink_a: ParSinkA,
sink_b: ParSinkB,
) -> Pin<Box<dyn Future<Output = (A, B)> + 'async_trait>>where
P: ThreadPool + 'async_trait,
ParSinkA: ParallelSink<Self::Item, Done = A> + 'async_trait,
ParSinkB: for<'a> ParallelSink<&'a Self::Item, Done = B> + 'static + 'async_trait,
<ParSinkA::Pipe as ParallelPipe<Self::Item>>::Task: 'static,
ParSinkA::ReduceA: 'static,
<ParSinkB as ParallelSink<&'static Self::Item>>::ReduceA: 'static,
<<ParSinkB as ParallelSink<&'static Self::Item>>::Pipe as ParallelPipe<&'static Self::Item>>::Task: 'static,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
A: 'async_trait,
B: 'async_trait,
'life0: 'async_trait,
fn group_by<'life0, 'async_trait, P, S, A, B>(
self,
pool: &'life0 P,
sink: S,
) -> Pin<Box<dyn Future<Output = IndexMap<A, S::Done>> + 'async_trait>>where
P: ThreadPool + 'async_trait,
A: Eq + Hash + Send + 'static + 'async_trait,
B: 'static + 'async_trait,
S: ParallelSink<B> + 'async_trait,
<S::Pipe as ParallelPipe<B>>::Task: Clone + Send + 'static,
S::ReduceA: 'static,
S::ReduceC: Clone,
S::Done: Send + 'static,
Self::Task: 'static,
Self: ParallelStream<Item = (A, B)> + Sized + 'async_trait,
'life0: 'async_trait,
fn collect<'life0, 'async_trait, P, B>(
self,
pool: &'life0 P,
) -> Pin<Box<dyn Future<Output = B> + 'async_trait>>where
P: ThreadPool + 'async_trait,
B: FromParallelStream<Self::Item> + 'async_trait,
B::ReduceA: Send + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn inspect<F>(self, f: F) -> Inspect<Self, F>
fn update<F>(self, f: F) -> Update<Self, F>
fn map<B, F>(self, f: F) -> Map<Self, F>
fn flat_map<B, F>(self, f: F) -> FlatMap<Self, F>
fn filter<F>(self, f: F) -> Filter<Self, F>
fn left_join<K, V1, V2>( self, right: impl IntoIterator<Item = (K, V2)>, ) -> LeftJoin<Self, K, V1, V2>
fn inner_join<K, V1, V2>( self, right: impl IntoIterator<Item = (K, V2)>, ) -> InnerJoin<Self, K, V1, V2>
fn chain<C>(self, chain: C) -> Chain<Self, C::ParStream>
fn for_each<'life0, 'async_trait, P, F>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = ()> + 'async_trait>>
fn fold<'life0, 'async_trait, P, ID, F, B>(
self,
pool: &'life0 P,
identity: ID,
op: F,
) -> Pin<Box<dyn Future<Output = B> + 'async_trait>>where
P: ThreadPool + 'async_trait,
ID: FnMut() -> B + Clone + Send + 'static + 'async_trait,
F: FnMut(B, Either<Self::Item, B>) -> B + Clone + Send + 'static + 'async_trait,
B: Send + 'static + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn count<'life0, 'async_trait, P>(
self,
pool: &'life0 P,
) -> Pin<Box<dyn Future<Output = usize> + 'async_trait>>where
P: ThreadPool + 'async_trait,
Self::Item: 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn sum<'life0, 'async_trait, P, S>( self, pool: &'life0 P, ) -> Pin<Box<dyn Future<Output = S> + 'async_trait>>
fn combine<'life0, 'async_trait, P, F>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>
fn max_by<'life0, 'async_trait, P, F>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>
fn max_by_key<'life0, 'async_trait, P, F, B>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>
fn min_by<'life0, 'async_trait, P, F>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>
fn min_by_key<'life0, 'async_trait, P, F, B>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = Option<Self::Item>> + 'async_trait>>
fn most_distinct<'life0, 'async_trait, P, A, B>(
self,
pool: &'life0 P,
n: usize,
probability: f64,
tolerance: f64,
error_rate: f64,
) -> Pin<Box<dyn Future<Output = Top<A, HyperLogLogMagnitude<B>>> + 'async_trait>>where
P: ThreadPool + 'async_trait,
Self: ParallelStream<Item = (A, B)> + Sized + 'async_trait,
A: Hash + Eq + Clone + Send + 'static + 'async_trait,
B: Hash + 'static + 'async_trait,
Self::Task: 'static,
'life0: 'async_trait,
fn sample_unstable<'life0, 'async_trait, P>(
self,
pool: &'life0 P,
samples: usize,
) -> Pin<Box<dyn Future<Output = SampleUnstable<Self::Item>> + 'async_trait>>where
P: ThreadPool + 'async_trait,
Self::Item: Send + 'static,
Self::Task: 'static,
Self: Sized + 'async_trait,
'life0: 'async_trait,
fn all<'life0, 'async_trait, P, F>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = bool> + 'async_trait>>
fn any<'life0, 'async_trait, P, F>( self, pool: &'life0 P, f: F, ) -> Pin<Box<dyn Future<Output = bool> + 'async_trait>>
Source§impl Stream for Never
impl Stream for Never
Auto Trait Implementations§
impl Freeze for Never
impl RefUnwindSafe for Never
impl Send for Never
impl Sync for Never
impl Unpin for Never
impl UnsafeUnpin for Never
impl UnwindSafe for Never
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> IntoDistributedStream for Twhere
T: DistributedStream,
impl<T> IntoDistributedStream for Twhere
T: DistributedStream,
type DistStream = T
type Item = <T as DistributedStream>::Item
fn into_dist_stream(self) -> <T as IntoDistributedStream>::DistStreamwhere
T: Sized,
fn par_stream_mut(&mut self) -> <&mut Self as IntoDistributedStream>::DistStreamwhere
for<'a> &'a mut Self: IntoDistributedStream,
fn dist_stream(&self) -> <&Self as IntoDistributedStream>::DistStreamwhere
for<'a> &'a Self: IntoDistributedStream,
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoParallelStream for Twhere
T: ParallelStream,
impl<T> IntoParallelStream for Twhere
T: ParallelStream,
type ParStream = T
type Item = <T as ParallelStream>::Item
fn into_par_stream(self) -> <T as IntoParallelStream>::ParStreamwhere
T: Sized,
fn par_stream_mut(&mut self) -> <&mut Self as IntoParallelStream>::ParStreamwhere
for<'a> &'a mut Self: IntoParallelStream,
fn par_stream(&self) -> <&Self as IntoParallelStream>::ParStreamwhere
for<'a> &'a Self: IntoParallelStream,
impl<T> ProcessSend for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T> StreamExt for T
impl<T> StreamExt for T
Source§fn next(&mut self) -> Next<'_, Self>where
Self: Unpin,
fn next(&mut self) -> Next<'_, Self>where
Self: Unpin,
Creates a future that resolves to the next item in the stream. Read more
Source§fn into_future(self) -> StreamFuture<Self>
fn into_future(self) -> StreamFuture<Self>
Source§fn map<T, F>(self, f: F) -> Map<Self, F>
fn map<T, F>(self, f: F) -> Map<Self, F>
Maps this stream’s items to a different type, returning a new stream of
the resulting type. Read more
Source§fn enumerate(self) -> Enumerate<Self>where
Self: Sized,
fn enumerate(self) -> Enumerate<Self>where
Self: Sized,
Creates a stream which gives the current iteration count as well as
the next value. Read more
Source§fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F>
fn filter<Fut, F>(self, f: F) -> Filter<Self, Fut, F>
Filters the values produced by this stream according to the provided
asynchronous predicate. Read more
Source§fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F>
fn filter_map<Fut, T, F>(self, f: F) -> FilterMap<Self, Fut, F>
Filters the values produced by this stream while simultaneously mapping
them to a different type according to the provided asynchronous closure. Read more
Source§fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F>
fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F>
Computes from this stream’s items new items of a different type using
an asynchronous closure. Read more
Source§fn collect<C>(self) -> Collect<Self, C>
fn collect<C>(self) -> Collect<Self, C>
Transforms a stream into a collection, returning a
future representing the result of that computation. Read more
Source§fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB>
fn unzip<A, B, FromA, FromB>(self) -> Unzip<Self, FromA, FromB>
Converts a stream of pairs into a future, which
resolves to pair of containers. Read more
Source§fn concat(self) -> Concat<Self>
fn concat(self) -> Concat<Self>
Concatenate all items of a stream into a single extendable
destination, returning a future representing the end result. Read more
Source§fn count(self) -> Count<Self>where
Self: Sized,
fn count(self) -> Count<Self>where
Self: Sized,
Drives the stream to completion, counting the number of items. Read more
Source§fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F>
fn fold<T, Fut, F>(self, init: T, f: F) -> Fold<Self, Fut, T, F>
Execute an accumulating asynchronous computation over a stream,
collecting all the values into one final result. Read more
Source§fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F>
fn any<Fut, F>(self, f: F) -> Any<Self, Fut, F>
Execute predicate over asynchronous stream, and return
true if any element in stream satisfied a predicate. Read moreSource§fn all<Fut, F>(self, f: F) -> All<Self, Fut, F>
fn all<Fut, F>(self, f: F) -> All<Self, Fut, F>
Execute predicate over asynchronous stream, and return
true if all element in stream satisfied a predicate. Read moreSource§fn flatten(self) -> Flatten<Self>
fn flatten(self) -> Flatten<Self>
Flattens a stream of streams into just one continuous stream. Read more
Source§fn flatten_unordered(
self,
limit: impl Into<Option<usize>>,
) -> FlattenUnorderedWithFlowController<Self, ()>
fn flatten_unordered( self, limit: impl Into<Option<usize>>, ) -> FlattenUnorderedWithFlowController<Self, ()>
Flattens a stream of streams into just one continuous stream. Polls
inner streams produced by the base stream concurrently. Read more
Source§fn flat_map_unordered<U, F>(
self,
limit: impl Into<Option<usize>>,
f: F,
) -> FlatMapUnordered<Self, U, F>
fn flat_map_unordered<U, F>( self, limit: impl Into<Option<usize>>, f: F, ) -> FlatMapUnordered<Self, U, F>
Maps a stream like
StreamExt::map but flattens nested Streams
and polls them concurrently, yielding items in any order, as they made
available. Read moreSource§fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F>
fn scan<S, B, Fut, F>(self, initial_state: S, f: F) -> Scan<Self, S, Fut, F>
Combinator similar to
StreamExt::fold that holds internal state
and produces a new stream. Read moreSource§fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F>
fn skip_while<Fut, F>(self, f: F) -> SkipWhile<Self, Fut, F>
Skip elements on this stream while the provided asynchronous predicate
resolves to
true. Read moreSource§fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F>
fn take_while<Fut, F>(self, f: F) -> TakeWhile<Self, Fut, F>
Take elements from this stream while the provided asynchronous predicate
resolves to
true. Read moreSource§fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut>
fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut>
Take elements from this stream until the provided future resolves. Read more
Source§fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F>
fn for_each<Fut, F>(self, f: F) -> ForEach<Self, Fut, F>
Runs this stream to completion, executing the provided asynchronous
closure for each element on the stream. Read more
Source§fn for_each_concurrent<Fut, F>(
self,
limit: impl Into<Option<usize>>,
f: F,
) -> ForEachConcurrent<Self, Fut, F>
fn for_each_concurrent<Fut, F>( self, limit: impl Into<Option<usize>>, f: F, ) -> ForEachConcurrent<Self, Fut, F>
Runs this stream to completion, executing the provided asynchronous
closure for each element on the stream concurrently as elements become
available. Read more
Source§fn take(self, n: usize) -> Take<Self>where
Self: Sized,
fn take(self, n: usize) -> Take<Self>where
Self: Sized,
Creates a new stream of at most
n items of the underlying stream. Read moreSource§fn skip(self, n: usize) -> Skip<Self>where
Self: Sized,
fn skip(self, n: usize) -> Skip<Self>where
Self: Sized,
Creates a new stream which skips
n items of the underlying stream. Read moreSource§fn catch_unwind(self) -> CatchUnwind<Self>where
Self: Sized + UnwindSafe,
fn catch_unwind(self) -> CatchUnwind<Self>where
Self: Sized + UnwindSafe,
Catches unwinding panics while polling the stream. Read more
Source§fn boxed<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + Send + 'a>>
fn boxed<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + Send + 'a>>
Wrap the stream in a Box, pinning it. Read more
Source§fn boxed_local<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a>>where
Self: Sized + 'a,
fn boxed_local<'a>(self) -> Pin<Box<dyn Stream<Item = Self::Item> + 'a>>where
Self: Sized + 'a,
Wrap the stream in a Box, pinning it. Read more
Source§fn buffered(self, n: usize) -> Buffered<Self>
fn buffered(self, n: usize) -> Buffered<Self>
An adaptor for creating a buffered list of pending futures. Read more
Source§fn buffer_unordered(self, n: usize) -> BufferUnordered<Self>
fn buffer_unordered(self, n: usize) -> BufferUnordered<Self>
An adaptor for creating a buffered list of pending futures (unordered). Read more
Source§fn zip<St>(self, other: St) -> Zip<Self, St>
fn zip<St>(self, other: St) -> Zip<Self, St>
An adapter for zipping two streams together. Read more
Source§fn peekable(self) -> Peekable<Self>where
Self: Sized,
fn peekable(self) -> Peekable<Self>where
Self: Sized,
Creates a new stream which exposes a
peek method. Read moreSource§fn chunks(self, capacity: usize) -> Chunks<Self>where
Self: Sized,
fn chunks(self, capacity: usize) -> Chunks<Self>where
Self: Sized,
An adaptor for chunking up items of the stream inside a vector. Read more
Source§fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>where
Self: Sized,
fn ready_chunks(self, capacity: usize) -> ReadyChunks<Self>where
Self: Sized,
An adaptor for chunking up ready items of the stream inside a vector. Read more
Source§fn forward<S>(self, sink: S) -> Forward<Self, S>
fn forward<S>(self, sink: S) -> Forward<Self, S>
A future that completes after the given stream has been fully processed
into the sink and the sink has been flushed and closed. Read more
Source§fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>)
fn split<Item>(self) -> (SplitSink<Self, Item>, SplitStream<Self>)
Source§fn inspect<F>(self, f: F) -> Inspect<Self, F>
fn inspect<F>(self, f: F) -> Inspect<Self, F>
Do something with each item of this stream, afterwards passing it on. Read more
Source§fn left_stream<B>(self) -> Either<Self, B>
fn left_stream<B>(self) -> Either<Self, B>
Source§fn right_stream<B>(self) -> Either<B, Self>
fn right_stream<B>(self) -> Either<B, Self>
Source§fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>where
Self: Unpin,
fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>where
Self: Unpin,
A convenience method for calling
Stream::poll_next on Unpin
stream types.