Trait amadeus::par_stream::StreamTask [−][src]
#[must_use] pub trait StreamTask { type Item; type Async: Stream; fn into_async(self) -> Self::Async; }
Associated Types
Required methods
fn into_async(self) -> Self::Async
[src]
fn into_async(self) -> Self::Async
[src]Implementations on Foreign Types
impl<A, B> StreamTask for Sum2<A, B> where
A: StreamTask,
B: StreamTask<Item = <A as StreamTask>::Item>,
[src]
impl<A, B> StreamTask for Sum2<A, B> where
A: StreamTask,
B: StreamTask<Item = <A as StreamTask>::Item>,
[src]type Item = <A as StreamTask>::Item
type Async = Sum2<<A as StreamTask>::Async, <B as StreamTask>::Async>
pub fn into_async(self) -> <Sum2<A, B> as StreamTask>::Async
[src]
Implementors
impl StreamTask for Never
[src]
impl StreamTask for Never
[src]impl<A, B> StreamTask for ChainTask<A, B> where
A: StreamTask,
B: StreamTask<Item = <A as StreamTask>::Item>,
[src]
impl<A, B> StreamTask for ChainTask<A, B> where
A: StreamTask,
B: StreamTask<Item = <A as StreamTask>::Item>,
[src]type Item = <A as StreamTask>::Item
type Async = ChainTask<<A as StreamTask>::Async, <B as StreamTask>::Async>
pub fn into_async(self) -> <ChainTask<A, B> as StreamTask>::Async
[src]
impl<C, F> StreamTask for FilterTask<C, F> where
C: StreamTask,
F: for<'a> FnMut<(&'a <C as StreamTask>::Item,), Output = bool>,
[src]
impl<C, F> StreamTask for FilterTask<C, F> where
C: StreamTask,
F: for<'a> FnMut<(&'a <C as StreamTask>::Item,), Output = bool>,
[src]type Item = <C as StreamTask>::Item
type Async = Filter<<C as StreamTask>::Async, F>
pub fn into_async(self) -> <FilterTask<C, F> as StreamTask>::Async
[src]
impl<C, F> StreamTask for InspectTask<C, F> where
C: StreamTask,
F: for<'a> FnMut<(&'a <C as StreamTask>::Item,), Output = ()> + Clone,
[src]
impl<C, F> StreamTask for InspectTask<C, F> where
C: StreamTask,
F: for<'a> FnMut<(&'a <C as StreamTask>::Item,), Output = ()> + Clone,
[src]type Item = <C as StreamTask>::Item
type Async = InspectTask<<C as StreamTask>::Async, F>
pub fn into_async(self) -> <InspectTask<C, F> as StreamTask>::Async
[src]
impl<C, F> StreamTask for UpdateTask<C, F> where
C: StreamTask,
F: for<'a> FnMut<(&'a mut <C as StreamTask>::Item,), Output = ()> + Clone,
[src]
impl<C, F> StreamTask for UpdateTask<C, F> where
C: StreamTask,
F: for<'a> FnMut<(&'a mut <C as StreamTask>::Item,), Output = ()> + Clone,
[src]type Item = <C as StreamTask>::Item
type Async = UpdateTask<<C as StreamTask>::Async, F>
pub fn into_async(self) -> <UpdateTask<C, F> as StreamTask>::Async
[src]
impl<C, F, R> StreamTask for FilterMapSyncTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = Option<R>> + Clone,
[src]
impl<C, F, R> StreamTask for FilterMapSyncTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = Option<R>> + Clone,
[src]type Item = R
type Async = FilterMapSync<<C as StreamTask>::Async, F>
pub fn into_async(self) -> <FilterMapSyncTask<C, F> as StreamTask>::Async
[src]
impl<C, F, R> StreamTask for FlatMapSyncTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
R: Iterator,
[src]
impl<C, F, R> StreamTask for FlatMapSyncTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
R: Iterator,
[src]type Item = <R as Iterator>::Item
type Async = FlatMapSync<<C as StreamTask>::Async, F, R>
pub fn into_async(self) -> <FlatMapSyncTask<C, F> as StreamTask>::Async
[src]
impl<C, F, R> StreamTask for FlatMapTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
R: Stream,
[src]
impl<C, F, R> StreamTask for FlatMapTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
R: Stream,
[src]type Item = <R as Stream>::Item
type Async = FlatMap<<C as StreamTask>::Async, F, R>
pub fn into_async(self) -> <FlatMapTask<C, F> as StreamTask>::Async
[src]
impl<C, F, R> StreamTask for MapSyncTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
[src]
impl<C, F, R> StreamTask for MapSyncTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
[src]type Item = R
type Async = Map<<C as StreamTask>::Async, F>
pub fn into_async(self) -> <MapSyncTask<C, F> as StreamTask>::Async
[src]
impl<C, F, R> StreamTask for MapTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
[src]
impl<C, F, R> StreamTask for MapTask<C, F> where
C: StreamTask,
F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone,
[src]type Item = R
type Async = Map<<C as StreamTask>::Async, F>
pub fn into_async(self) -> <MapTask<C, F> as StreamTask>::Async
[src]
impl<I, T, E, U> StreamTask for IntoTask<I, U> where
I: StreamTask<Item = Result<T, E>>,
T: Into<U>,
[src]
impl<I, T, E, U> StreamTask for IntoTask<I, U> where
I: StreamTask<Item = Result<T, E>>,
T: Into<U>,
[src]impl<T> StreamTask for IterStreamTask<T>
[src]
impl<T> StreamTask for IterStreamTask<T>
[src]