pub fn ping_pong() -> ChunkExpand description
Two flows, one Atomic Hop round-trip: main sends a Message to
pong, pong replies with payload+1 via msg_reply_cap, main returns
that payload (2).
Requires crate::std_native_table (make_msg / msg_*).
Every Send carries exactly one crate::Value::Message and targets a
crate::Value::Cap ÔÇö bare ints / pids trap (Atomic Hop + FlowCap).
Examples found in repository?
examples/ping_pong.rs (line 10)
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}