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
17
18
19
20
21
22
23
24
25

use bytes::Bytes;
use serde::{de::DeserializeOwned, Serialize};

use super::{EventAttribute, EventCodec};

#[derive(Debug)]
pub struct Json<T: Serialize + DeserializeOwned>(pub T);

impl<T: Serialize + DeserializeOwned> EventCodec for Json<T> {
    fn to_bytes(&self) -> Bytes {
        Bytes::from(serde_json::to_vec(&self.0).expect("the type cannot be converted to json"))
    }
    fn from_bytes(bytes: Bytes) -> Option<Self> {
        serde_json::from_slice(&bytes).ok().map(Json)
    }
}

impl<T> EventAttribute for Json<T>
where
    T: Serialize + DeserializeOwned + EventAttribute,
{
    const SUBJECT: crate::prelude::Subject = T::SUBJECT;
    const BROADCAST: bool = T::BROADCAST;
    const EXPECT_ACK_KIND: crate::prelude::MessageAckExpectKind = T::EXPECT_ACK_KIND;
}