Struct Serializer 

pub struct Serializer<T: Write>(/* private fields */);

Implementations

impl<W: Write> Serializer<W>

pub fn new(w: W) -> Self

Examples found in repository

examples/stream.rs (line 7)

fn main() {
    let buf = Vec::new();
    let mut stream_serializer = Serializer::new(buf);
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.serialize(Value::from(true)).unwrap();
    stream_serializer.serialize(Value::from(false)).unwrap();
    stream_serializer.serialize(Value::from("test")).unwrap();
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.flush().unwrap();
    println!("{:?}", stream_serializer.get_ref());

    let buf_reader = BufReader::new(Cursor::new(stream_serializer.get_ref()));
    let stream_deserializer = messagepack_rs::stream::deserializer::Deserializer::<Value, _>::new(buf_reader);
    stream_deserializer.for_each(|v| println!("{:?}", v));
}

pub fn serialize<T: Serializable>( &mut self, value: T, ) -> Result<usize, SerializeError>

Examples found in repository

examples/stream.rs (line 8)

fn main() {
    let buf = Vec::new();
    let mut stream_serializer = Serializer::new(buf);
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.serialize(Value::from(true)).unwrap();
    stream_serializer.serialize(Value::from(false)).unwrap();
    stream_serializer.serialize(Value::from("test")).unwrap();
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.flush().unwrap();
    println!("{:?}", stream_serializer.get_ref());

    let buf_reader = BufReader::new(Cursor::new(stream_serializer.get_ref()));
    let stream_deserializer = messagepack_rs::stream::deserializer::Deserializer::<Value, _>::new(buf_reader);
    stream_deserializer.for_each(|v| println!("{:?}", v));
}

pub fn get_ref(&self) -> &W

Examples found in repository

examples/stream.rs (line 14)

fn main() {
    let buf = Vec::new();
    let mut stream_serializer = Serializer::new(buf);
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.serialize(Value::from(true)).unwrap();
    stream_serializer.serialize(Value::from(false)).unwrap();
    stream_serializer.serialize(Value::from("test")).unwrap();
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.flush().unwrap();
    println!("{:?}", stream_serializer.get_ref());

    let buf_reader = BufReader::new(Cursor::new(stream_serializer.get_ref()));
    let stream_deserializer = messagepack_rs::stream::deserializer::Deserializer::<Value, _>::new(buf_reader);
    stream_deserializer.for_each(|v| println!("{:?}", v));
}

pub fn flush(&mut self) -> Result<(), Error>

Examples found in repository

examples/stream.rs (line 13)

fn main() {
    let buf = Vec::new();
    let mut stream_serializer = Serializer::new(buf);
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.serialize(Value::from(true)).unwrap();
    stream_serializer.serialize(Value::from(false)).unwrap();
    stream_serializer.serialize(Value::from("test")).unwrap();
    stream_serializer.serialize(Value::Nil).unwrap();
    stream_serializer.flush().unwrap();
    println!("{:?}", stream_serializer.get_ref());

    let buf_reader = BufReader::new(Cursor::new(stream_serializer.get_ref()));
    let stream_deserializer = messagepack_rs::stream::deserializer::Deserializer::<Value, _>::new(buf_reader);
    stream_deserializer.for_each(|v| println!("{:?}", v));
}