diath 0.5.1

diath is a light-weight library for communication between tokio async tasks
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

use crate::enquiry::answer::Responder;
use crate::enquiry::question::Questioner;

#[test]
fn test1() {
    tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .unwrap()
        .block_on(async {
            let (question, answer) = super::new(3);
            let q1 = tokio::task::spawn(number_interrogator(question.clone(), 1));
            let q2 = tokio::task::spawn(eager_interrogator(question.clone(), 2));
            let q3 = tokio::task::spawn(number_interrogator(question, 3));
            let end = tokio::task::spawn(suspect(answer));
            assert!(q1.await.unwrap());
            assert!(q2.await.unwrap());
            assert!(q3.await.unwrap());
            assert!(end.await.unwrap());
        })
}

async fn number_interrogator(question: Questioner<u8, u16>, v: u8) -> bool {
    let question = question.ask(v).await.unwrap();
    question.listen().await.unwrap() == (v as u16) * 2
}

async fn eager_interrogator(question: Questioner<u8, u16>, v: u8) -> bool {
    question.ask_and_listen(v).await.unwrap() == (v as u16) * 2
}

async fn suspect(mut answer: Responder<u8, u16>) -> bool {
    while let Some(question) = answer.listen().await {
        let value = *question as u16;
        question.answer(value * 2).unwrap();
    }
    true
}