Method decode_eof

libs/@local/codec/src/bytes.rs:220–235

Decodes any remaining data when the stream has ended. # Errors - if reading the line fails - if the JSON content is invalid - if the JSON doesn't match type `T`

(&mut self, buf: &mut BytesMut)

    /// - if the JSON content is invalid
    /// - if the JSON doesn't match type `T`
    fn decode_eof(&mut self, buf: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error> {
        self.lines
            .decode_eof(buf)
            .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()
    }
}

#[cfg(test)]