Struct pusherator::InputBuild

pub struct InputBuild<T>(/* private fields */);

Implementations

impl<T> InputBuild<T>

pub fn new() -> Self

Trait Implementations

impl<T> Default for InputBuild<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> PusheratorBuild for InputBuild<T>

type ItemOut = T

type Output<O: Pusherator<Item = Self::ItemOut>> = O

fn push_to<O>(self, input: O) -> Self::Output<O>

where O: Pusherator<Item = Self::ItemOut>,

fn map<Func, Out>(self, func: Func) -> MapBuild<Self, Func>

where Self: Sized, Func: FnMut(Self::ItemOut) -> Out,

fn inspect<Func>(self, func: Func) -> InspectBuild<Self, Func>

where Self: Sized, Func: FnMut(&Self::ItemOut),

fn filter<Func>(self, func: Func) -> FilterBuild<Self, Func>

where Self: Sized, Func: FnMut(&Self::ItemOut) -> bool,

fn unzip<Next1, Item2>(self, next1: Next1) -> UnzipBuild<Self, Next1>

where Self: Sized + PusheratorBuild<ItemOut = (Next1::Item, Item2)>, Next1: Pusherator,

fn switch<Next1, Item2>(self, next1: Next1) -> SwitchBuild<Self, Next1>

where Self: Sized + PusheratorBuild<ItemOut = Either<Next1::Item, Item2>>, Next1: Pusherator,

fn for_each<Func>( self, func: Func ) -> Self::Output<ForEach<Func, Self::ItemOut>>

where Self: Sized, Func: FnMut(Self::ItemOut),

fn demux<Func, Nexts>( self, func: Func, nexts: Nexts ) -> Self::Output<Demux<Func, Nexts, Self::ItemOut>>

where Self: Sized, Nexts: PusheratorList, Func: FnMut(Self::ItemOut, &mut Nexts),