Trait indicator::operator::Operator

pub trait Operator<I> {
    type Output;
    fn next(&mut self, input: I) -> Self::Output;
}

Operator.

Associated Types

type Output

Output type.

Required methods

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

Produce the next output.

Implementors

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::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::Output as Tickable>::Value>>

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::Output>

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::Output as Tickable>::Value, <P2::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::Output, P2::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::Output>