Skip to main content

stream/
stream.rs

1use messagepack_rs::stream::serializer::Serializer;
2use messagepack_rs::value::Value;
3use std::io::{BufReader, Cursor};
4
5fn main() {
6    let buf = Vec::new();
7    let mut stream_serializer = Serializer::new(buf);
8    stream_serializer.serialize(Value::Nil).unwrap();
9    stream_serializer.serialize(Value::from(true)).unwrap();
10    stream_serializer.serialize(Value::from(false)).unwrap();
11    stream_serializer.serialize(Value::from("test")).unwrap();
12    stream_serializer.serialize(Value::Nil).unwrap();
13    stream_serializer.flush().unwrap();
14    println!("{:?}", stream_serializer.get_ref());
15
16    let buf_reader = BufReader::new(Cursor::new(stream_serializer.get_ref()));
17    let stream_deserializer = messagepack_rs::stream::deserializer::Deserializer::<Value, _>::new(buf_reader);
18    stream_deserializer.for_each(|v| println!("{:?}", v));
19}