asteroid-mq 0.1.0-alpha.3

An embeddable message queue system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use super::Codec;

#[derive(Debug, Copy, Clone, PartialEq, Eq, Hash)]
pub struct Json;

impl Codec for Json {
    fn decode(
        &self,
        bytes: &[u8],
    ) -> Result<crate::protocol::node::edge::EdgePayload, super::CodecError> {
        serde_json::from_slice(bytes).map_err(super::CodecError::decode_error)
    }
    fn encode(&self, value: &crate::protocol::node::edge::EdgePayload) -> Vec<u8> {
        serde_json::to_vec(value).expect("json encode failed")
    }
}