Trait StreamTask 

pub trait StreamTask {
    type Item;
    type Async: Stream<Item = Self::Item>;

    // Required method
    fn into_async(self) -> Self::Async;
}

Required Associated Types

type Item

type Async: Stream<Item = Self::Item>

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>

type Item = <A as StreamTask>::Item

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

fn into_async(self) -> Self::Async

Implementors

impl StreamTask for Never

type Item = Never

type Async = Never

impl<A, B, C, RefAItem> StreamTask for JoinTask<A, B, C, RefAItem>

where A: StreamTask, B: PipeTask<A::Item>, C: PipeTask<RefAItem>,

type Item = Sum2<<B as PipeTask<<A as StreamTask>::Item>>::Output, <C as PipeTask<RefAItem>>::Output>

type Async = JoinStreamTaskAsync<<A as StreamTask>::Async, <B as PipeTask<<A as StreamTask>::Item>>::Async, <C as PipeTask<RefAItem>>::Async, RefAItem, <A as StreamTask>::Item>

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

type Item = <A as StreamTask>::Item

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

impl<C: StreamTask, F> StreamTask for FilterTask<C, F>

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

type Item = <C as StreamTask>::Item

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

impl<C: StreamTask, F> StreamTask for InspectTask<C, F>

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

type Item = <C as StreamTask>::Item

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

impl<C: StreamTask, F> StreamTask for UpdateTask<C, F>

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

type Item = <C as StreamTask>::Item

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

impl<C: StreamTask, F, R> StreamTask for FilterMapSyncTask<C, F>

where F: FnMut<(C::Item,), Output = Option<R>> + Clone,

type Item = R

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

impl<C: StreamTask, F, R> StreamTask for MapSyncTask<C, F>

where F: FnMut<(C::Item,), Output = R> + Clone,

type Item = R

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

impl<C: StreamTask, F, R> StreamTask for MapTask<C, F>

where F: FnMut<(C::Item,), Output = R> + Clone,

type Item = R

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

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

type Item = <R as Iterator>::Item

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

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

type Item = <R as Stream>::Item

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

impl<T> StreamTask for IterStreamTask<T>

type Item = T

type Async = IterStreamTask<T>