Trait indicator::operator::Operator

pub trait Operator<I> {
    type Output;

    fn next(&mut self, input: I) -> Self::Output;
}

Operator.

Required Associated Types

type Output

Output type.

Required Methods

fn next(&mut self, input: I) -> Self::Output

Produce the next output.

Implementations on Foreign Types

impl<I, P> Operator<I> for Box<P> where
    P: Operator<I> + ?Sized, 

type Output = <P as Operator<I>>::Output

fn next(&mut self, input: I) -> Self::Output

Implementors

impl<I, I1, I2, P1, P2> Operator<I> for Tuple<I, P1, P2> where
    I: Tickable<Value = (I1, I2)>,
    P1: Operator<TickValue<I1>>,
    P2: Operator<TickValue<I2>>,
    P1::Output: Tickable,
    P2::Output: Tickable, 

type Output = TickValue<(<<P1 as Operator<TickValue<I1>>>::Output as Tickable>::Value, <<P2 as Operator<TickValue<I2>>>::Output as Tickable>::Value)>

impl<I, O, F> Operator<I> for indicator::ticked::map::Map<F> where
    I: Tickable,
    F: FnMut(<I as Tickable>::Value) -> O, 

type Output = TickValue<O>

impl<I, O, F> Operator<I> for indicator::operator::map::Map<F> where
    F: FnMut(I) -> O, 

type Output = O

impl<I, P1, P2> Operator<I> for Then<I, P1, P2> where
    P1: Operator<I>,
    P2: Operator<P1::Output>, 

type Output = <P2 as Operator<<P1 as Operator<I>>::Output>>::Output

impl<I, Q, P> Operator<I> for indicator::ticked::facet::FacetMap<I, Q, P> where
    I: Tickable + Clone,
    Q: Eq + Hash + Clone,
    P: Operator<I>,
    P::Output: Tickable, 

type Output = TickValue<HashMap<Q, <<P as Operator<I>>::Output as Tickable>::Value, RandomState>>

impl<I, Q, P> Operator<I> for indicator::operator::facet::FacetMap<I, Q, P> where
    I: Clone,
    Q: Eq + Hash + Clone,
    P: Operator<I>, 

type Output = HashMap<Q, <P as Operator<I>>::Output, RandomState>

impl<I, T, P, const LEN: usize> Operator<I> for Array<I, P, LEN> where
    I: Tickable<Value = [T; LEN]>,
    P: Operator<TickValue<T>>,
    P::Output: Tickable, 

type Output = TickValue<[<<P as Operator<TickValue<T>>>::Output as Tickable>::Value; LEN]>

impl<I: Tickable + Clone, P1, P2> Operator<I> for indicator::ticked::facet::Facet<I, P1, P2> where
    P1: Operator<I>,
    P2: Operator<I>,
    P1::Output: Tickable,
    P2::Output: Tickable, 

type Output = TickValue<(<<P1 as Operator<I>>::Output as Tickable>::Value, <<P2 as Operator<I>>::Output as Tickable>::Value)>

impl<I: Clone, P1, P2> Operator<I> for indicator::operator::facet::Facet<I, P1, P2> where
    P1: Operator<I>,
    P2: Operator<I>, 

type Output = (<P1 as Operator<I>>::Output, <P2 as Operator<I>>::Output)

impl<M: TumblingWindow, I: Tickable, Q: QueueCapAtLeast<LEN>, P: TumblingOperation<I::Value, Q, LEN>, const LEN: usize> Operator<I> for TumblingOperator<M, Q, P, LEN>

type Output = TickValue<<P as TumblingOperation<<I as Tickable>::Value, Q, LEN>>::Output>