Struct StreamDeserializer 

pub struct StreamDeserializer { /* private fields */ }

Reads a stream of MessagePack items into items (see deser::stream).

The items of the stream follow each other without separators. An item is complete once its last byte was read. Reading continues after items that fail to deserialize, items that are not well-formed end the stream.

Items which do not borrow are deserialized while their input arrives (see StreamDeserializer::feed) so only incomplete atoms (like strings) are buffered.

use deser_msgpack::DeserializerConfig;

let mut reader =
    DeserializerConfig::new().reader(&[0x01, 0xa2, b'h', b'i'][..]);
assert_eq!(reader.read::<u32>().unwrap(), Some(1));
assert_eq!(reader.read::<String>().unwrap().as_deref(), Some("hi"));
assert_eq!(reader.read::<u32>().unwrap(), None);

Items are parsed like with a Deserializer, so they can borrow from the stream’s buffer (see InputBuffer::deserialize).

Implementations

impl StreamDeserializer

pub fn new() -> StreamDeserializer

Creates a stream deserializer.

pub fn with_config(config: &DeserializerConfig) -> StreamDeserializer

Creates a stream deserializer with the given configuration.

pub fn config(&self) -> &DeserializerConfig

Returns the configuration.

Trait Implementations

impl Debug for StreamDeserializer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamDeserializer

fn default() -> StreamDeserializer

Returns the “default value” for a type.

impl StreamDeserializer for StreamDeserializer

fn frame(&mut self, input: &[u8], eof: bool) -> Result<Frame, Error>

Finds the next value in the input.

fn drive_frame<'de>( &mut self, frame: &'de [u8], driver: &mut DeserializeDriver<'_, 'de>, ) -> Result<(), Error>

Deserializes a value from its frame.

fn supports_feed(&self) -> bool

Returns true if the deserializer implements feed.

fn feed( &mut self, input: &[u8], offset: usize, eof: bool, driver: &mut DeserializeDriver<'_, '_>, ) -> Result<Progress, Error>

Deserializes a value while its input arrives.

fn peek(&mut self, input: &[u8], eof: bool) -> Result<Option<Progress>, Error>

Finds the start of the next value without deserializing it.

fn is_text(&self) -> bool

Returns true if the format is text.