fluxrpc-core 0.31.0

RPC framework supporting multiple protocols and codecs
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

pub trait Codec: Clone + Sync + Send + 'static {
    fn encode<T: serde::Serialize>(&self, value: &T) -> anyhow::Result<Vec<u8>>;
    fn decode<T: serde::de::DeserializeOwned>(&self, data: &[u8]) -> anyhow::Result<T>;
}

pub mod json {
    use crate::codec::Codec;
    use serde::Serialize;
    use serde::de::DeserializeOwned;

    #[derive(Clone)]
    pub struct JsonCodec;

    impl JsonCodec {
        pub fn new() -> Self {
            Self {}
        }
    }

    impl Codec for JsonCodec {
        fn encode<T: Serialize>(&self, value: &T) -> anyhow::Result<Vec<u8>> {
            let json = serde_json::to_vec(value)?;
            Ok(json)
        }

        fn decode<T: DeserializeOwned>(&self, data: &[u8]) -> anyhow::Result<T> {
            let val = serde_json::from_slice(data)?;
            Ok(val)
        }
    }
}