Trait amadeus::par_stream::StreamTask

#[must_use]pub trait StreamTask where
    <Self::Async as Stream>::Item == Self::Item, {
    type Item;
    type Async: Stream;
    fn into_async(self) -> Self::Async;
}

Associated Types

type Item

type Async: Stream

Loading content...

Required methods

fn into_async(self) -> Self::Async

Loading content...

Implementations on Foreign Types

impl<A, B> StreamTask for Sum2<A, B> where
    A: StreamTask,
    B: StreamTask<Item = <A as StreamTask>::Item>, 

type Item = <A as StreamTask>::Item

type Async = Sum2<<A as StreamTask>::Async, <B as StreamTask>::Async>

fn into_async(self) -> <Sum2<A, B> as StreamTask>::Async

Loading content...

Implementors

impl StreamTask for Never

type Item = Never

type Async = Never

fn into_async(self) -> <Never as StreamTask>::Async

impl<A, B> StreamTask for ChainTask<A, B> where
    A: StreamTask,
    B: StreamTask<Item = <A as StreamTask>::Item>, 

type Item = <A as StreamTask>::Item

type Async = ChainTask<<A as StreamTask>::Async, <B as StreamTask>::Async>

fn into_async(self) -> <ChainTask<A, B> as StreamTask>::Async

impl<C, F> StreamTask for FilterTask<C, F> where
    C: StreamTask,
    F: for<'a> FnMut<(&'a <C as StreamTask>::Item,), Output = bool>, 

type Item = <C as StreamTask>::Item

type Async = Filter<<C as StreamTask>::Async, F>

fn into_async(self) -> <FilterTask<C, F> as StreamTask>::Async

impl<C, F> StreamTask for InspectTask<C, F> where
    C: StreamTask,
    F: for<'a> FnMut<(&'a <C as StreamTask>::Item,), Output = ()> + Clone, 

type Item = <C as StreamTask>::Item

type Async = InspectTask<<C as StreamTask>::Async, F>

fn into_async(self) -> <InspectTask<C, F> as StreamTask>::Async

impl<C, F> StreamTask for UpdateTask<C, F> where
    C: StreamTask,
    F: for<'a> FnMut<(&'a mut <C as StreamTask>::Item,), Output = ()> + Clone, 

type Item = <C as StreamTask>::Item

type Async = UpdateTask<<C as StreamTask>::Async, F>

fn into_async(self) -> <UpdateTask<C, F> as StreamTask>::Async

impl<C, F, R> StreamTask for FilterMapSyncTask<C, F> where
    C: StreamTask,
    F: FnMut<(<C as StreamTask>::Item,), Output = Option<R>> + Clone, 

type Item = R

type Async = FilterMapSync<<C as StreamTask>::Async, F>

fn into_async(self) -> <FilterMapSyncTask<C, F> as StreamTask>::Async

impl<C, F, R> StreamTask for FlatMapSyncTask<C, F> where
    C: StreamTask,
    F: Clone + FnMut<(<C as StreamTask>::Item,), Output = R>,
    R: Iterator, 

type Item = <R as Iterator>::Item

type Async = FlatMapSync<<C as StreamTask>::Async, F, R>

fn into_async(self) -> <FlatMapSyncTask<C, F> as StreamTask>::Async

impl<C, F, R> StreamTask for FlatMapTask<C, F> where
    C: StreamTask,
    F: Clone + FnMut<(<C as StreamTask>::Item,), Output = R>,
    R: Stream, 

type Item = <R as Stream>::Item

type Async = FlatMap<<C as StreamTask>::Async, F, R>

fn into_async(self) -> <FlatMapTask<C, F> as StreamTask>::Async

impl<C, F, R> StreamTask for MapSyncTask<C, F> where
    C: StreamTask,
    F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone, 

type Item = R

type Async = Map<<C as StreamTask>::Async, F>

fn into_async(self) -> <MapSyncTask<C, F> as StreamTask>::Async

impl<C, F, R> StreamTask for MapTask<C, F> where
    C: StreamTask,
    F: FnMut<(<C as StreamTask>::Item,), Output = R> + Clone, 

type Item = R

type Async = Map<<C as StreamTask>::Async, F>

fn into_async(self) -> <MapTask<C, F> as StreamTask>::Async

impl<I, T, E, U> StreamTask for IntoTask<I, U> where
    I: StreamTask<Item = Result<T, E>>,
    T: Into<U>, 

type Item = Result<U, E>

type Async = IntoTask<I::Async, U>

fn into_async(self) -> Self::Async

impl<T> StreamTask for IterStreamTask<T>

type Item = T

type Async = IterStreamTask<T>

fn into_async(self) -> <IterStreamTask<T> as StreamTask>::Async

Loading content...