Struct Step 

pub struct Step<'p, INPUT> { /* private fields */ }

Logical step in the line

Implementations

impl<'p, INPUT> Step<'p, INPUT>

where INPUT: StepInput,

pub fn is_active(&self) -> bool

Returns if the step is active (can be passed)

pub fn new(value: INPUT) -> Self

Creates a new step

pub fn then_any<OUTPUT, A, A2, F, F2>( self, action1: A, action2: A2, ) -> Step<'p, OUTPUT>

where A: Into<Action<'p, F, INPUT, OUTPUT>>, F: FnOnce(INPUT) -> Option<OUTPUT>, A2: Into<Action<'p, F2, INPUT, OUTPUT>>, F2: FnOnce(INPUT) -> Option<OUTPUT>, INPUT: Clone,

Passes the step in case if any of the actions returns Some

pub fn then<OUTPUT, A, F>(self, action: A) -> Step<'p, OUTPUT>

where A: Into<Action<'p, F, INPUT, OUTPUT>>, F: FnOnce(INPUT) -> Option<OUTPUT>,

Passes the step in case if the action returns Some

Examples found in repository

examples/fan_control.rs (line 16)

fn main() {
    let mut state = Rack::new().with_recording_enabled();
    let mut processor = state.processor();

    // Some fan state
    let mut fan = false;

    // A temperature sensor value
    let temperature = 31.0;

    processor
        // a sequence to turn on the fan on if the temperature is above 30 degrees
        .line("fan_on", temperature)
        .then(action!("temp_high", |t| (t > 30.0).then_some(())))
        .then(action!("fan_on", |()| {
            fan = true;
            Some(())
        }));
    processor
        // a sequence to turn off the fan if the temperature is below 25 degrees
        .line("fan_off", temperature)
        .then(action!("temp_low", |t| (t < 25.0).then_some(())))
        .then(action!("fan_off", |()| {
            fan = false;
            Some(())
        }));

    state.ingress(&mut processor);
    println!("{}", state);

    println!("{}", serde_json::to_string_pretty(&state).unwrap());
}