Swim 序列化的 MessagePack 支持。

为 Swim 序列化系统提供 MessagePack 后端。这包括两部分

• A 函数 read_from_msg_pack 试图从包含 MessagePack 数据的缓冲区反序列化任何实现 swimos_form::read::StructuralReadable 的类型。
• 类型 MsgPackInterpreter 实现 swimos_form::write::StructuralWriter 允许任何实现 swimos_form::write::StructuralWritable 的类型序列化为 MessagePack。

示例

use bytes::{BufMut, BytesMut};
use swimos_form::write::StructuralWritable;
use swimos_msgpack::{read_from_msg_pack, MsgPackInterpreter};

let mut buffer = BytesMut::with_capacity(128);
let data = vec!["first".to_owned(), "second".to_owned(), "third".to_owned()];
let mut writer = (&mut buffer).writer();

let interpreter = MsgPackInterpreter::new(&mut writer);
assert!(data.write_with(interpreter).is_ok());

let mut bytes = buffer.split().freeze();
let restored = read_from_msg_pack::<Vec<String>, _>(&mut bytes);

assert_eq!(restored, Ok(data));