Method decode

libs/@local/codec/src/bytes.rs:196–211

Decodes a JSON line into a value of type `T`. # Performance This method has time complexity dependent on the length of the line being decoded. JSON parsing complexity is approximately O(n) where n is the length of the input string. # Errors - if reading the line fails - if the JSON content is invalid - if the JSON doesn't match type `T`

(&mut self, src: &mut BytesMut)

    /// - if the JSON content is invalid
    /// - if the JSON doesn't match type `T`
    fn decode(&mut self, src: &mut BytesMut) -> Result<Option<T>, Self::Error> {
        self.lines
            .decode(src)
            .inspect(|_| {
                self.current_line += 1;
            })
            .map_err(io::Error::other)?
            .filter(|line| !line.is_empty())
            .map(|line| {
                serde_json::from_str(&line)
                    .map_err(io::Error::from)
                    .attach_with(|| format!("line in input: {}", self.current_line))
                    .attach_with(|| line.clone())
            })
            .transpose()
    }

    /// Decodes any remaining data when the stream has ended.
    ///