[−][src]Trait amadeus_core::par_stream::StreamTask
Associated Types
Loading content...Required methods
fn into_async(self) -> Self::Async
Implementations on Foreign Types
impl<A: StreamTask, B: StreamTask<Item = A::Item>> StreamTask for Sum2<A, B>
[src]
Loading content...
Implementors
impl StreamTask for Never
[src]
impl<A: StreamTask, B: StreamTask<Item = A::Item>> StreamTask for ChainTask<A, B>
[src]
type Item = A::Item
type Async = ChainTask<A::Async, B::Async>
fn into_async(self) -> Self::Async
[src]
impl<C: StreamTask, F> StreamTask for FilterTask<C, F> where
F: for<'a> FnMut<(&'a C::Item,), Output = bool>,
[src]
F: for<'a> FnMut<(&'a C::Item,), Output = bool>,
impl<C: StreamTask, F> StreamTask for InspectTask<C, F> where
F: for<'a> FnMut<(&'a C::Item,), Output = ()> + Clone,
[src]
F: for<'a> FnMut<(&'a C::Item,), Output = ()> + Clone,
impl<C: StreamTask, F> StreamTask for UpdateTask<C, F> where
F: for<'a> FnMut<(&'a mut C::Item,), Output = ()> + Clone,
[src]
F: for<'a> FnMut<(&'a mut C::Item,), Output = ()> + Clone,
impl<C: StreamTask, F, R> StreamTask for MapTask<C, F> where
F: FnMut<(C::Item,), Output = R> + Clone,
[src]
F: FnMut<(C::Item,), Output = R> + Clone,