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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

#[servify::service(
    impls = [
        SimpleCounter_increment_and_get,
        SimpleCounter_get,
        SimpleCounter_set,
        SimpleCounter_reset,
    ]
)]
struct SimpleCounter {
    pub counter: u32,
}

#[servify::export]
impl SimpleCounter {
    fn increment_and_get(&mut self) -> u32 {
        self.counter += 1;
        self.counter
    }

    fn get(&self) -> u32 {
        self.counter
    }

    fn set(&mut self, value: u32) {
        self.counter = value;
    }

    fn reset(&mut self) {
        self.counter = 0;
    }
}

#[tokio::test]
async fn main() {
    let (counter_rx, counter_client) = SimpleCounter::initiate_message_passing(32);

    tokio::spawn(async move {
        SimpleCounter::Server { counter: 0 }
            .listen(counter_rx)
            .await;
    });

    assert_eq!(counter_client.increment_and_get().await, 1);
    assert_eq!(counter_client.increment_and_get().await, 2);
    assert_eq!(counter_client.get().await, 2);
    counter_client.set(10).await;
    assert_eq!(counter_client.get().await, 10);
    counter_client.reset().await;
    assert_eq!(counter_client.get().await, 0);
}