Skip to main content

arc_malachitebft_engine/ser/
borsh.rs

1use crate::util::streaming::StreamId;
2
3impl borsh::BorshSerialize for StreamId {
4    fn serialize<W: borsh::io::Write>(&self, writer: &mut W) -> borsh::io::Result<()> {
5        self.0.to_vec().serialize(writer)
6    }
7}
8
9impl borsh::BorshDeserialize for StreamId {
10    fn deserialize_reader<R: borsh::io::Read>(reader: &mut R) -> borsh::io::Result<Self> {
11        let bytes = Vec::<u8>::deserialize_reader(reader)?;
12        Ok(StreamId(bytes.into()))
13    }
14}