Skip to content

Commit ca3feac

Browse files
jecsand838scovich
andauthored
Update arrow-avro/src/reader/mod.rs
Co-authored-by: Ryan Johnson <[email protected]>
1 parent 3b5d497 commit ca3feac

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

arrow-avro/src/reader/mod.rs

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -379,11 +379,7 @@ impl<R: BufRead> Iterator for Reader<R> {
379379
type Item = Result<RecordBatch, ArrowError>;
380380

381381
fn next(&mut self) -> Option<Self::Item> {
382-
match self.read() {
383-
Ok(Some(batch)) => Some(Ok(batch)),
384-
Ok(None) => None,
385-
Err(e) => Some(Err(e)),
386-
}
382+
self.read().transpose()
387383
}
388384
}
389385

0 commit comments

Comments
 (0)