servify 0.1.1

A macro for effortlessly enabling message passing, inter-process communication, HTTP/TCP server functionality, and more with a unified implementation in struct methods.
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

#[servify::service(
    impls = [
        Counter_increment_and_get,
        Counter_get_value,
    ]
)]
struct Counter {
    pub count: u32,
}

#[servify::export]
impl Counter {
    fn increment_and_get(&mut self, count: u32) -> u32 {
        self.count += count;
        self.count
    }
    fn get_value(&self) -> u32 {
        self.count
    }
}

#[tokio::test]
async fn count_up() {
    let (rx, client) = Counter::initiate_message_passing(32);

    tokio::spawn(async move {
        Counter::Server { count: 3 }.listen(rx).await;
    });

    assert_eq!(client.get_value().await, 3);
    assert_eq!(client.increment_and_get(5).await, 8);
    assert_eq!(client.get_value().await, 8);
    assert_eq!(client.increment_and_get(3).await, 11);
    assert_eq!(client.get_value().await, 11);
}