Struct serde_json::de::StreamDeserializer [−][src]
Iterator that deserializes a stream into multiple JSON values.
A stream deserializer can be created from any JSON deserializer using the
Deserializer::into_iter
method.
The data can consist of any JSON value. Values need to be a self-delineating value e.g. arrays, objects, or strings, or be followed by whitespace or a self-delineating value.
extern crate serde_json; use serde_json::{Deserializer, Value}; fn main() { let data = "{\"k\": 3}1\"cool\"\"stuff\" 3{} [0, 1, 2]"; let stream = Deserializer::from_str(data).into_iter::<Value>(); for value in stream { println!("{}", value.unwrap()); } }
Methods
impl<'de, R, T> StreamDeserializer<'de, R, T> where
R: Read<'de>,
T: Deserialize<'de>,
[src]
[−]
impl<'de, R, T> StreamDeserializer<'de, R, T> where
R: Read<'de>,
T: Deserialize<'de>,
pub fn new(read: R) -> Self
[src]
[−]
pub fn new(read: R) -> Self
Create a JSON stream deserializer from one of the possible serde_json input sources.
Typically it is more convenient to use one of these methods instead:
- Deserializer::from_str(...).into_iter()
- Deserializer::from_bytes(...).into_iter()
- Deserializer::from_reader(...).into_iter()
pub fn byte_offset(&self) -> usize
[src]
[−]
pub fn byte_offset(&self) -> usize
Returns the number of bytes so far deserialized into a successful T
.
If a stream deserializer returns an EOF error, new data can be joined to
old_data[stream.byte_offset()..]
to try again.
let data = b"[0] [1] ["; let de = serde_json::Deserializer::from_slice(data); let mut stream = de.into_iter::<Vec<i32>>(); assert_eq!(0, stream.byte_offset()); println!("{:?}", stream.next()); // [0] assert_eq!(3, stream.byte_offset()); println!("{:?}", stream.next()); // [1] assert_eq!(7, stream.byte_offset()); println!("{:?}", stream.next()); // error assert_eq!(8, stream.byte_offset()); // If err.is_eof(), can join the remaining data to new data and continue. let remaining = &data[stream.byte_offset()..];
Note: In the future this method may be changed to return the number of bytes so far deserialized into a successful T or syntactically valid JSON skipped over due to a type error. See serde-rs/json#70 for an example illustrating this.
Trait Implementations
impl<'de, R, T> Iterator for StreamDeserializer<'de, R, T> where
R: Read<'de>,
T: Deserialize<'de>,
[src]
[+]
impl<'de, R, T> Iterator for StreamDeserializer<'de, R, T> where
R: Read<'de>,
T: Deserialize<'de>,
Auto Trait Implementations
impl<'de, R, T> Send for StreamDeserializer<'de, R, T> where
R: Send,
T: Send,
impl<'de, R, T> Send for StreamDeserializer<'de, R, T> where
R: Send,
T: Send,
impl<'de, R, T> Sync for StreamDeserializer<'de, R, T> where
R: Sync,
T: Sync,
impl<'de, R, T> Sync for StreamDeserializer<'de, R, T> where
R: Sync,
T: Sync,