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

/// This test is to be sure that macro use full path calls without any trait imported
#[test]
#[allow(dead_code)]
fn test_server_task_enum_define() {
    use nix::errno::Errno;
    use razor_stream::server::task::ServerTaskVariantFull;
    use razor_stream_macros::server_task_enum;
    use serde_derive::{Deserialize, Serialize};

    #[derive(Serialize, Deserialize, Debug, Default, PartialEq)]
    struct FileOpenReq {
        pub path: String,
    }

    #[derive(Serialize, Deserialize, Debug, Default, PartialEq)]
    struct FileReadReq {
        pub path: String,
        pub offset: u64,
        pub len: u64,
    }

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

    #[server_task_enum(req, resp, error=Errno)]
    #[derive(Debug)]
    pub enum FileServerTask {
        #[action(1)]
        Open(ServerTaskVariantFull<FileServerTask, FileOpenReq, (), Errno>),
        #[action(2)]
        Read(ServerTaskVariantFull<FileServerTask, FileReadReq, (), Errno>),
    }
}