We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a61da1e commit a1cedb4Copy full SHA for a1cedb4
parquet/src/arrow/async_reader/mod.rs
@@ -179,7 +179,7 @@ impl<T: AsyncRead + AsyncSeek + Unpin + Send> AsyncFileReader for T {
179
let mut buffer = Vec::with_capacity(to_read);
180
let read = self.take(to_read as u64).read_to_end(&mut buffer).await?;
181
if read != to_read {
182
- eof_err!("expected to read {} bytes, got {}", to_read, read);
+ return Err(eof_err!("expected to read {} bytes, got {}", to_read, read));
183
}
184
185
Ok(buffer.into())
0 commit comments