chorus_lib 0.5.0

Choreographic Programming in Rust
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

extern crate chorus_lib;
use chorus_lib::core::{ChoreoOp, Choreography, ChoreographyLocation, Located, LocationSet};
#[derive(ChoreographyLocation)]
struct Alice;
#[derive(ChoreographyLocation)]
struct Bob;
#[derive(ChoreographyLocation)]
struct Carol;

struct DemoChoreography {
    input: Located<String, Alice>,
}

impl Choreography for DemoChoreography {
    type L = LocationSet!(Alice);
    fn run(self, op: &impl ChoreoOp<Self::L>) {
        op.locally(Alice, |un| {
            let s = un.unwrap(&self.input);
            println!("Alice received: {}", s);
        });
    }
}

fn main() {
    let runner = chorus_lib::core::Runner::new();
    let s = "hello, world".to_string();
    let s = runner.local(s);
    let choreo = DemoChoreography { input: s };
    runner.run(choreo);
}