Method fill_buf

datafusion/datasource-json/src/utils.rs:357–362

(&mut self)

impl<R: Read> BufRead for JsonArrayToNdjsonReader<R> {
    fn fill_buf(&mut self) -> std::io::Result<&[u8]> {
        if self.output_pos >= self.output_filled {
            self.fill_output_buffer()?;
        }
        Ok(&self.output_buffer[self.output_pos..self.output_filled])
    }

    fn consume(&mut self, amt: usize) {
        self.output_pos = std::cmp::min(self.output_pos + amt, self.output_filled);