jaq-interpret 1.5.0

Interpreter for the jaq language
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
43
44
45
46
47
48
49
50

use alloc::boxed::Box;

pub type BoxIter<'a, T> = Box<dyn Iterator<Item = T> + 'a>;

/// Return a boxed iterator that yields a single element.
pub fn box_once<'a, T: 'a>(x: T) -> BoxIter<'a, T> {
    Box::new(core::iter::once(x))
}

/// For every element `y` returned by `l`, return the output of `r(y, x)`.
///
/// In case that `l` returns only a single element, this does not clone `x`.
pub fn map_with<'a, T: Clone + 'a, U: 'a, V: 'a>(
    mut l: impl Iterator<Item = U> + 'a,
    x: T,
    r: impl Fn(U, T) -> V + 'a,
) -> BoxIter<'a, V> {
    // this special case is to avoid cloning `x`
    if l.size_hint().1 == Some(1) {
        if let Some(ly) = l.next() {
            // the Rust documentation states that
            // "a buggy iterator may yield [..] more than the upper bound of elements",
            // but so far, it seems that all iterators here are not buggy :)
            assert!(l.next().is_none());
            return box_once(r(ly, x));
        }
    }
    Box::new(l.map(move |ly| r(ly, x.clone())))
}

/// For every element `y` returned by `l`, return the outputs of `r(y, x)`.
///
/// In case that `l` returns only a single element, this does not clone `x`.
pub fn flat_map_with<'a, T: Clone + 'a, U: 'a, V: 'a>(
    mut l: impl Iterator<Item = U> + 'a,
    x: T,
    r: impl Fn(U, T) -> BoxIter<'a, V> + 'a,
) -> BoxIter<'a, V> {
    // this special case is to avoid cloning `x`
    if l.size_hint().1 == Some(1) {
        if let Some(ly) = l.next() {
            // the Rust documentation states that
            // "a buggy iterator may yield [..] more than the upper bound of elements",
            // but so far, it seems that all iterators here are not buggy :)
            assert!(l.next().is_none());
            return Box::new(r(ly, x));
        }
    }
    Box::new(l.flat_map(move |ly| r(ly, x.clone())))
}