Struct StreamDeserializer 

pub struct StreamDeserializer<'de, T> { /* private fields */ }

A streaming deserializer that reads a sequence of YSON values from an input buffer.

In many YSON use cases, data is provided as a sequence of top-level values optionally separated by semicolons (e.g., 1; 2; 3;). StreamDeserializer allows you to lazily iterate through these values without having to wrap them in a list [...].

Examples

use ytsaurus_yson::de::StreamDeserializer;

let input = b"1; 2; 3";
let mut stream = StreamDeserializer::<i32>::new(input, false);

assert_eq!(stream.next_item().unwrap(), Some(1));
assert_eq!(stream.next_item().unwrap(), Some(2));
assert_eq!(stream.next_item().unwrap(), Some(3));
assert_eq!(stream.next_item().unwrap(), None); // End of stream

Implementations

impl<'de, T> StreamDeserializer<'de, T>

where T: Deserialize<'de>,

pub fn new(input: &'de [u8], is_binary: bool) -> Self

Creates a new StreamDeserializer from the given byte slice.

Arguments

• input - The raw byte slice containing a sequence of YSON values.
• is_binary - true for binary format, false for text format.

pub fn next_item(&mut self) -> Result<Option<T>, YsonError>

Deserializes the next item in the stream.

Returns

• Ok(Some(T)) if a value was successfully deserialized.
• Ok(None) if the end of the input was reached.
• Err(YsonError) if a parsing error occurred or if the data doesn’t match type T.

Errors

This method will return an error if:

• The YSON syntax is malformed.
• An item separator (semicolon) is missing where one is expected.
• The input ends prematurely after a separator.