dialectic 0.4.1

Transport-polymorphic, asynchronous session types for 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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

use dialectic::prelude::*;
use std::error::Error;
use tokio::io::{BufReader, Stdin, Stdout};

mod common;
#[allow(unused)]
use common::{demo, prompt};

#[tokio::main]
async fn main() {
    demo::<Server, _, _, _, _, _, _>(&server, &client, usize::MAX).await;
}

/// The session from the client's perspective.
type Client = Session! {
    // Fill this in...
};

/// The implementation of the client.
#[Transmitter(Tx for /* add types needed by session here */)]
#[Receiver(Rx for /* add types needed by session here */)]
async fn client<Tx, Rx>(
    #[allow(unused)] mut input: BufReader<Stdin>,
    #[allow(unused)] mut output: Stdout,
    #[allow(unused_mut)] mut chan: Chan<Client, Tx, Rx>,
) -> Result<(), Box<dyn Error>>
where
    Tx::Error: Error + Send,
    Rx::Error: Error + Send,
{
    // Do something with the channel...
    chan.close();
    Ok(())
}

/// The session from the server's perspective.
type Server = <Client as Session>::Dual;

/// The implementation of the server for each client connection.
#[Transmitter(Tx for /* add types needed by session here */)]
#[Receiver(Rx for /* add types needed by session here */ )]
async fn server<Tx, Rx>(
    #[allow(unused_mut)] mut chan: Chan<Server, Tx, Rx>,
) -> Result<(), Box<dyn Error>>
where
    Tx::Error: Error + Send,
    Rx::Error: Error + Send,
{
    // Do something with the channel...
    chan.close();
    Ok(())
}