refault 0.3.0

deterministic simulation framework for distributed systems using async
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use refault::{executor::spawn, sim_builder::SimBuilder, time::sleep};
use std::time::Duration;

fn main() {
    SimBuilder::default()
        .run(|| async {
            // Spawn multiple futures for simultaneous execution
            let future1 = spawn(calculate_async());
            let future2 = spawn(calculate_async());

            let val1 = future1.await.unwrap();
            let val2 = future2.await.unwrap();

            println!("{}", val1 + val2);
        })
        .unwrap();
}

async fn calculate_async() -> u32 {
    sleep(Duration::from_secs(5)).await;
    5
}