Method next

src/avro/src/reader.rs:153–168

(&mut self)

    type Item = Result<Block, AvroError>;

    fn next(&mut self) -> Option<Self::Item> {
        assert!(self.inner.is_empty());

        match self.inner.read_block_next() {
            Ok(()) => {
                if self.inner.is_empty() {
                    None
                } else {
                    let bytes = std::mem::take(&mut self.inner.buf);
                    let len = std::mem::take(&mut self.inner.messages_remaining);
                    Some(Ok(Block { bytes, len }))
                }
            }
            Err(e) => Some(Err(e)),
        }
    }
}

impl<R: AvroRead> Reader<R> {