ping_pong/
ping_pong.rs

1//! Two flows, one Atomic Hop round-trip (`Value::Message`).
2//!
3//! ```text
4//! cargo run -p byteflow-actors --example ping_pong
5//! ```
6
7use byteflow::{samples, std_native_table, FlowOutcome, Runtime, RuntimeConfig, Value};
8
9fn main() {
10    let chunk = samples::ping_pong();
11    let rt = match Runtime::with_natives_and_config(
12        chunk,
13        std_native_table(),
14        RuntimeConfig {
15            workers: 1,
16            quantum: 10_000,
17            mailbox: byteflow::MailboxConfig::DEFAULT,
18            ..Default::default()
19        },
20    ) {
21        Ok(rt) => rt,
22        Err(e) => {
23            eprintln!("runtime: {e}");
24            std::process::exit(1);
25        }
26    };
27    let Some(main) = rt.function_index("main") else {
28        eprintln!("missing main");
29        std::process::exit(1);
30    };
31    let handle = match rt.spawn(main, &[]) {
32        Ok(h) => h,
33        Err(e) => {
34            eprintln!("spawn: {e}");
35            std::process::exit(1);
36        }
37    };
38    let outcome = handle.join();
39    let metrics = rt.metrics();
40    rt.shutdown();
41
42    match outcome {
43        FlowOutcome::Completed(Value::Int(2)) => {
44            println!("pong replied 2 (Atomic Hop)");
45            println!("{metrics}");
46        }
47        other => {
48            eprintln!("unexpected {other:?}");
49            std::process::exit(1);
50        }
51    }
52}
ping_pong/ping_pong.rs

ping_pong/
ping_pong.rs
