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        },
19    ) {
20        Ok(rt) => rt,
21        Err(e) => {
22            eprintln!("runtime: {e}");
23            std::process::exit(1);
24        }
25    };
26    let Some(main) = rt.function_index("main") else {
27        eprintln!("missing main");
28        std::process::exit(1);
29    };
30    let handle = match rt.spawn(main, &[]) {
31        Ok(h) => h,
32        Err(e) => {
33            eprintln!("spawn: {e}");
34            std::process::exit(1);
35        }
36    };
37    let outcome = handle.join();
38    let metrics = rt.metrics();
39    rt.shutdown();
40
41    match outcome {
42        FlowOutcome::Completed(Value::Int(2)) => {
43            println!("pong replied 2 (Atomic Hop)");
44            println!("{metrics}");
45        }
46        other => {
47            eprintln!("unexpected {other:?}");
48            std::process::exit(1);
49        }
50    }
51}
ping_pong/ping_pong.rs

ping_pong/
ping_pong.rs
