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

use super::GatOperator;

/// Operator returns by [`map`].
#[derive(Debug, Clone, Copy)]
pub struct Map<F>(pub(super) F);

/// Convert the input directly.
/// ```
/// use indicator::gat::*;
///
/// fn plus_one() -> impl for<'out> GatOperator<usize, Output<'out> = usize> {
///     map(|x| x + 1)
/// }
/// ```
pub fn map<I, O, F>(f: F) -> Map<F>
where
    F: FnMut(I) -> O,
{
    Map(f)
}

impl<I, O, F> GatOperator<I> for Map<F>
where
    F: FnMut(I) -> O,
{
    type Output<'out> = O where F: 'out, I: 'out;

    #[inline]
    fn next<'out>(&'out mut self, input: I) -> Self::Output<'out>
    where
        I: 'out,
    {
        (self.0)(input)
    }
}