ame-bus 0.3.0

A NATS tool for JSON messages
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use serde::de::Error;

pub mod rpc;
pub mod simple_push;

pub trait NatsJsonMessage
where Self: serde::Serialize + for <'de> serde::de::Deserialize<'de> + Sized + Send
{
    const SUBJECT: &'static str;
    fn to_json_bytes(&self) -> Result<Vec<u8>, serde_json::Error> {
        let json = serde_json::to_string(self)?;
        Ok(json.into_bytes())
    }
    fn from_json_bytes(bytes: &[u8]) -> Result<Self, serde_json::Error> {
        let json = std::str::from_utf8(bytes).map_err(|_| serde_json::Error::custom("Failed to parse string from bytes"))?;
        let rpc_request = serde_json::from_str(json)?;
        Ok(rpc_request)
    }
}