flowsamples 0.25.0

A set of sample 'flow' programs
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

use flow_impl::Implementation;
use flow_impl_derive::FlowImpl;
use serde_json::json;
use serde_json::Value;
use serde_json::Value::String as JsonString;

#[derive(FlowImpl, Debug)]
pub struct Reverser;

impl Implementation for Reverser {
    fn run(&self, inputs: &[Value]) -> (Option<Value>, bool) {
        let mut value = None;

        let input = &inputs[0];
        match input {
            JsonString(ref s) => {
                value = Some(json!({
                    "reversed" : s.chars().rev().collect::<String>(),
                    "original": s
                }));
            }
            _ => {}
        }

        (value, true)
    }
}