indicator 0.4.4

Abstractions for stream aggregation, we call them `Indicator` s.
Documentation 
1
2
3
4
5
6
7
8
9
10

pub use self::operator::OperatorProcessor;
use super::{Publisher, Subscriber};

/// Operator Processor.
pub mod operator;

/// Processor.
pub trait Processor<'a, I>: Subscriber<I> + Publisher<'a> {}

impl<'a, I, P> Processor<'a, I> for P where P: Subscriber<I> + Publisher<'a> {}