vino_codec/
messagepack.rs

1use std::io::Cursor;
2
3use rmp_serde::{Deserializer, Serializer};
4use serde::{Deserialize, Serialize};
5
6use crate::error::CodecError;
7use crate::Result;
8
9#[doc(hidden)]
10pub fn rmp_serialize<T>(item: &T) -> std::result::Result<Vec<u8>, rmp_serde::encode::Error>
11where
12  T: ?Sized + Serialize,
13{
14  let mut buf = Vec::new();
15  match item.serialize(
16    &mut Serializer::new(&mut buf)
17      .with_string_variants()
18      .with_struct_map(),
19  ) {
20    Ok(_) => Ok(buf),
21    Err(e) => Err(e),
22  }
23}
24
25/// The standard function for serializing codec structs into a format that can be.
26/// used for message exchange between actor and host. Use of any other function to.
27/// serialize could result in breaking incompatibilities.
28pub fn serialize<T>(item: &T) -> Result<Vec<u8>>
29where
30  T: ?Sized + Serialize,
31{
32  rmp_serialize(item).map_err(CodecError::MessagePackSerializationError)
33}
34
35#[doc(hidden)]
36pub fn rmp_deserialize<'de, T: Deserialize<'de>>(
37  buf: &[u8],
38) -> std::result::Result<T, rmp_serde::decode::Error> {
39  let mut de = Deserializer::new(Cursor::new(buf));
40  Deserialize::deserialize(&mut de)
41}
42
43/// The standard function for de-serializing codec structs from a format suitable.
44/// for message exchange between actor and host. Use of any other function to.
45/// deserialize could result in breaking incompatibilities.
46pub fn deserialize<'de, T: Deserialize<'de>>(buf: &[u8]) -> Result<T> {
47  rmp_deserialize(buf).map_err(CodecError::MessagePackDeserializationError)
48}
vino_codec/messagepack.rs

vino_codec/
messagepack.rs
