isola 0.4.2

Isola runtime
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

#[macro_export]
macro_rules! args {
    () => {
        ::core::result::Result::<[$crate::sandbox::Arg; 0], $crate::value::Error>::Ok([])
    };
    ($($tokens:tt)+) => {{
        (|| -> ::core::result::Result<_, $crate::value::Error> {
            Ok($crate::__isola_args_internal!(@array [] $($tokens)+))
        })()
    }};
}

#[doc(hidden)]
#[macro_export]
macro_rules! __isola_args_internal {
    (@array [$($out:expr,)*]) => {
        [$($out,)*]
    };
    (@array [$($out:expr,)*] , $($rest:tt)*) => {
        $crate::__isola_args_internal!(@array [$($out,)*] $($rest)*)
    };
    (@array [$($out:expr,)*] @stream($stream:expr) $(, $($rest:tt)*)?) => {
        $crate::__isola_args_internal!(
            @array
            [
                $($out,)*
                $crate::sandbox::Arg::PositionalStream(::std::boxed::Box::pin($stream)),
            ]
            $($($rest)*)?
        )
    };
    (@array [$($out:expr,)*] $name:ident = @stream($stream:expr) $(, $($rest:tt)*)?) => {
        $crate::__isola_args_internal!(
            @array
            [
                $($out,)*
                $crate::sandbox::Arg::NamedStream(
                    ::std::string::String::from(stringify!($name)),
                    ::std::boxed::Box::pin($stream),
                ),
            ]
            $($($rest)*)?
        )
    };
    (@array [$($out:expr,)*] $name:ident = $value:expr $(, $($rest:tt)*)?) => {
        $crate::__isola_args_internal!(
            @array
            [
                $($out,)*
                $crate::sandbox::Arg::Named(
                    ::std::string::String::from(stringify!($name)),
                    $crate::value::Value::from_serde(&$value)?,
                ),
            ]
            $($($rest)*)?
        )
    };
    (@array [$($out:expr,)*] $value:expr $(, $($rest:tt)*)?) => {
        $crate::__isola_args_internal!(
            @array
            [
                $($out,)*
                $crate::sandbox::Arg::Positional($crate::value::Value::from_serde(&$value)?),
            ]
            $($($rest)*)?
        )
    };
}

#[cfg(test)]
mod tests {
    use futures::stream;

    use crate::{sandbox::Arg, value::Value};

    #[test]
    fn args_macro_supports_positional_and_named_values() {
        let args = crate::sandbox::args![1_i64, x = 3_i64, y = "ok"].expect("args");
        assert_eq!(args.len(), 3);

        match &args[0] {
            Arg::Positional(value) => {
                assert_eq!(value.to_serde::<i64>().expect("i64"), 1);
            }
            _ => panic!("unexpected variant"),
        }
        match &args[1] {
            Arg::Named(name, value) => {
                assert_eq!(name, "x");
                assert_eq!(value.to_serde::<i64>().expect("i64"), 3);
            }
            _ => panic!("unexpected variant"),
        }
        match &args[2] {
            Arg::Named(name, value) => {
                assert_eq!(name, "y");
                assert_eq!(value.to_serde::<String>().expect("string"), "ok");
            }
            _ => panic!("unexpected variant"),
        }
    }

    #[test]
    fn args_macro_supports_stream_markers() {
        let stream_arg = stream::empty::<Value>();
        let named_stream = stream::empty::<Value>();
        let args = crate::sandbox::args![@stream(stream_arg), x = @stream(named_stream), y = 2_i64]
            .expect("args");
        assert_eq!(args.len(), 3);
        assert!(matches!(args[0], Arg::PositionalStream(_)));
        assert!(matches!(args[1], Arg::NamedStream(_, _)));
        match &args[2] {
            Arg::Named(name, value) => {
                assert_eq!(name, "y");
                assert_eq!(value.to_serde::<i64>().expect("i64"), 2);
            }
            _ => panic!("unexpected variant"),
        }
    }
}