razor-stream 0.9.0

The streaming interface of razor-rpc. razor-rpc is a modular, pluggable RPC for high throughput scenario, supports various runtimes, with a low-level streaming interface, and high-level remote API call interface.
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
53
54

/// This test is to be sure that macro use full path calls without any trait imported
#[test]
#[allow(dead_code)]
fn test_client_task_enum_define() {
    use crossfire::{MTx, mpsc};
    use nix::errno::Errno;
    use razor_stream::client::task::ClientTaskCommon;
    use razor_stream::error::RpcError;
    use razor_stream_macros::{client_task, client_task_enum};

    #[derive(PartialEq)]
    #[repr(u8)]
    enum FileAction {
        Open = 1,
        Close = 2,
    }

    #[client_task(debug)]
    pub struct FileOpenTask {
        #[field(common)]
        common: ClientTaskCommon,
        #[field(req)]
        req: String,
        #[field(resp)]
        resp: Option<()>,
        #[field(res)]
        res: Option<Result<(), RpcError<Errno>>>,
        #[field(noti)]
        noti: Option<MTx<mpsc::List<FileTask>>>,
    }

    #[client_task(2, debug)] // This action will be used as the variant doesn't specify one
    pub struct FileCloseTask {
        #[field(common)]
        common: ClientTaskCommon,
        #[field(req)]
        req: (),
        #[field(resp)]
        resp: Option<()>,
        #[field(res)]
        res: Option<Result<(), RpcError<Errno>>>,
        #[field(noti)]
        noti: Option<MTx<mpsc::List<FileTask>>>,
    }

    #[client_task_enum(error = Errno)]
    #[derive(Debug)]
    pub enum FileTask {
        #[action(FileAction::Open)]
        Open(FileOpenTask),
        // This variant delegates action to the inner type
        Close(FileCloseTask),
    }
}