Trait amadeus_core::par_stream::StreamTask

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

Associated Types

type Item

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

Loading content...

Required methods

fn into_async(self) -> Self::Async

Loading content...

Implementations on Foreign Types

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

type Item = A::Item

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

fn into_async(self) -> Self::Async

Loading content...

Implementors

impl StreamTask for Never

type Item = Self

type Async = Self

fn into_async(self) -> Self::Async

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

type Item = A::Item

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

fn into_async(self) -> Self::Async

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

type Item = C::Item

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

fn into_async(self) -> Self::Async

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

type Item = C::Item

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

fn into_async(self) -> Self::Async

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

type Item = C::Item

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

fn into_async(self) -> Self::Async

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::Async, F, R>

fn into_async(self) -> Self::Async

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

type Item = R::Item

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

fn into_async(self) -> Self::Async

impl<T> StreamTask for IterStreamTask<T>

type Item = T

type Async = IterStreamTask<T>

fn into_async(self) -> Self::Async

Loading content...