ranvier-runtime 0.37.0

Async Execution Engine for Ranvier
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

use serde::{Deserialize, Serialize};

use ranvier_core::timeline::{Timeline, TimelineEvent};
use ranvier_core::{Bus, Outcome, Transition};
use ranvier_runtime::Axon;

#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
pub enum TestInfallible {}

#[derive(Clone)]
struct AddOne;

#[async_trait::async_trait]
impl Transition<u32, u32> for AddOne {
    type Error = TestInfallible;
    type Resources = ();

    async fn run(
        &self,
        state: u32,
        _resources: &Self::Resources,
        _bus: &mut Bus,
    ) -> Outcome<u32, Self::Error> {
        Outcome::next(state + 1)
    }
}

#[tokio::test]
async fn timeline_assertion_works_in_integration_test() {
    let axon = Axon::<u32, u32, TestInfallible, ()>::new("TimelineFlow").then(AddOne);

    let mut bus = Bus::new();
    bus.insert(Timeline::new());

    let outcome = axon.execute(41, &(), &mut bus).await;
    match outcome {
        Outcome::Next(value) => assert_eq!(value, 42),
        _ => panic!("expected Outcome::Next"),
    }

    let timeline = bus
        .read::<Timeline>()
        .expect("timeline should remain available for assertion");

    assert!(
        timeline
            .events
            .iter()
            .any(|event| matches!(event, TimelineEvent::NodeEnter { .. })),
        "timeline should include at least one NodeEnter event"
    );
    assert!(
        timeline
            .events
            .iter()
            .any(|event| matches!(event, TimelineEvent::NodeExit { .. })),
        "timeline should include at least one NodeExit event"
    );
}