indicator 0.4.4

Abstractions for stream aggregation, we call them `Indicator` s.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

/// The definition of the operators of indicators and some helpers
pub mod operator;

/// Helpers for operators with [`Tickable`](crate::Tickable) output.
pub mod tick_operator;

/// Tumbling operator.
pub mod tumbling_operator;

/// Utils.
pub mod utils;

pub use operator::{identity::id, map::map, mux::mux, GatOperator, GatOperatorExt};
pub use tick_operator::{map_tick::map_t, TickGatOperatorExt};
pub use tumbling_operator::{
    operator::{tumbling, TumblingOperator},
    periodic::{Periodic, PeriodicOp, TickQueueRef},
    queue::{circular::Circular, Change, Queue, QueueRef, Tumbling},
};