Struct AsyncJsonStreamReader 

pub struct AsyncJsonStreamReader<R> { /* private fields */ }

The main async JSON stream reader for selective parsing.

Implementations

impl<R: AsyncRead + Unpin> AsyncJsonStreamReader<R>

pub fn new(reader: R) -> Self

Create a new stream reader with the default internal buffer size.

pub async fn next_token( &mut self, ) -> Result<Option<JsonToken>, AsyncJsonStreamReaderError>

Read the next JSON token from the stream.

This is a low-level API; avoid mixing it with next_object_entry-based helpers.

pub async fn next_object_entry( &mut self, ) -> Result<Option<String>, AsyncJsonStreamReaderError>

Read the next object key and position the reader on its value.

pub async fn skip_to_key( &mut self, target_key: &str, ) -> Result<(), AsyncJsonStreamReaderError>

Skip to a specific key in the current object without descending into nested objects.

After this returns Ok(()), the reader is positioned on the value for target_key. Use read_* methods to consume that value before calling next_object_entry.

pub async fn skip_object(&mut self) -> Result<(), AsyncJsonStreamReaderError>

Skip the next object value entirely.

pub async fn start_array_item( &mut self, ) -> Result<bool, AsyncJsonStreamReaderError>

Read the next item in an array.

Returns true if an item was read, false if the array ended.

pub async fn start_object(&mut self) -> Result<(), AsyncJsonStreamReaderError>

Start reading an object.

pub async fn read_string( &mut self, ) -> Result<String, AsyncJsonStreamReaderError>

Read a string value.

pub async fn read_nullable_string( &mut self, ) -> Result<Option<String>, AsyncJsonStreamReaderError>

Read a nullable string value.

pub async fn read_number<T>(&mut self) -> Result<T, AsyncJsonStreamReaderError>

where T: FromStr, <T as FromStr>::Err: Debug,

Read a number value.

pub async fn read_boolean(&mut self) -> Result<bool, AsyncJsonStreamReaderError>

Read a boolean value.

pub async fn read_key( &mut self, ) -> Result<Option<String>, AsyncJsonStreamReaderError>

Read the next key in an object.

pub async fn deserialize_object( &mut self, ) -> Result<Map<String, Value>, AsyncJsonStreamReaderError>

Read an object and deserialize it into a JSON map.