Trait indicator::ticked::tumbling::cached::CachedOperation

pub trait CachedOperation<I, Q: QueueCapAtLeast<LEN, Item = I>, const LEN: usize> {
    type Output;
    fn call(&mut self, q: &Q, new_period: bool, x: &I) -> Self::Output;

    fn share_with<P>(self, op: P) -> Shared<I, Self, P>
    where
        P: CachedOperation<I, Q, LEN>,
        Self: Sized,
    { ... }
}

Tumbling operations that apply on the cached inputs.

Associated Types

type Output

The output type.

Required methods

fn call(&mut self, q: &Q, new_period: bool, x: &I) -> Self::Output

Call.

Provided methods

fn share_with<P>(self, op: P) -> Shared<I, Self, P> where
    P: CachedOperation<I, Q, LEN>,
    Self: Sized, 

Share the cached queue with other cached operation.

Implementors

impl<F, I, O, Q: QueueCapAtLeast<LEN, Item = I>, const LEN: usize> CachedOperation<I, Q, LEN> for F where
    F: FnMut(&Q, bool, &I) -> O, 

type Output = O

impl<I, Q: QueueCapAtLeast<LEN, Item = I>, K, P, const LEN: usize> CachedOperation<I, Q, LEN> for SharedMap<I, K, P> where
    K: Clone + Eq + Hash,
    P: CachedOperation<I, Q, LEN>, 

type Output = HashMap<K, P::Output>

impl<I, Q: QueueCapAtLeast<LEN, Item = I>, P1, P2, const LEN: usize> CachedOperation<I, Q, LEN> for Shared<I, P1, P2> where
    P1: CachedOperation<I, Q, LEN>,
    P2: CachedOperation<I, Q, LEN>, 

type Output = (P1::Output, P2::Output)