in avro/src/ser_schema.rs [175:189]
fn write_buffered_items(&mut self) -> Result<(), Error> {
if !self.item_buffers.is_empty() {
self.bytes_written +=
encode_long(self.item_buffers.len() as i64, &mut self.ser.writer)?;
for item in self.item_buffers.drain(..) {
self.bytes_written += self
.ser
.writer
.write(item.as_slice())
.map_err(Error::WriteBytes)?;
}
}
Ok(())
}