Skip to main content

acktor_ipc/codec/
ipc_message.rs

1use bytes::{Bytes, BytesMut};
2
3use acktor_ipc_proto::ipc_message::IpcMessage;
4
5use super::errors::{DecodeError, EncodeError};
6use super::{Decode, DecodeContext, Encode, EncodeContext};
7
8impl Encode for IpcMessage {
9    #[inline]
10    fn encoded_len(&self) -> usize {
11        prost::Message::encoded_len(self)
12    }
13
14    #[inline]
15    fn encode(&self, buf: &mut BytesMut, _ctx: Option<&EncodeContext>) -> Result<(), EncodeError> {
16        prost::Message::encode(self, buf).map_err(Into::into)
17    }
18}
19
20impl Decode for IpcMessage {
21    #[inline]
22    fn decode(buf: Bytes, _ctx: Option<&DecodeContext>) -> Result<Self, DecodeError> {
23        prost::Message::decode(buf).map_err(Into::into)
24    }
25}