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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use super::GatOperator;

/// Operator returns by [`mux`].
#[derive(Debug, Clone, Copy)]
pub struct Mux<P1, P2>(pub(super) P1, pub(super) P2);

/// Use two operators simultaneously.
/// ```
/// use indicator::gat::*;
///
/// fn plus_mul() -> impl for<'out> GatOperator<usize, Output<'out> = usize> {
///     mux(map(|x| x + 1), map(|x| x * 2)).map(|(x, y)| x + y)
/// }
/// ```
pub fn mux<I, P1, P2>(op1: P1, op2: P2) -> Mux<P1, P2>
where
    I: Clone,
    P1: GatOperator<I>,
    P2: GatOperator<I>,
{
    Mux(op1, op2)
}

impl<I, P1, P2> GatOperator<I> for Mux<P1, P2>
where
    I: Clone,
    P1: GatOperator<I>,
    P2: GatOperator<I>,
{
    type Output<'out> = (P1::Output<'out>, P2::Output<'out>)
    where
        I: 'out,
        P1: 'out,
        P2: 'out;

    fn next<'out>(&'out mut self, input: I) -> Self::Output<'out>
    where
        I: 'out,
    {
        (self.0.next(input.clone()), self.1.next(input))
    }
}