connection_utils/codecs/generic_codec/
encoder.rs

1use std::io::Error;
2
3use bytes::BytesMut;
4use serde::{Serialize, de::DeserializeOwned};
5use tokio_util::codec::Encoder;
6
7use super::GenericCodec;
8
9impl<T: Serialize + DeserializeOwned> Encoder<T> for GenericCodec<T> {
10    type Error = Error;
11
12    fn encode(
13        &mut self,
14        message: T,
15        dist_buff: &mut BytesMut,
16    ) -> Result<(), Self::Error> {
17        let bytes = serde_json::to_string(&message)
18            .expect("Cannot serialize message to bytes.");
19        
20        return Encoder::encode(
21            &mut self.length_delimited_codec, 
22            bytes.into(),
23            dist_buff,
24        );
25    }
26}