We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3d6a204 commit 3ec7448Copy full SHA for 3ec7448
parquet/src/arrow/async_reader/mod.rs
@@ -653,6 +653,8 @@ where
653
/// - `Ok(Some(reader))` which holds all the data for the row group.
654
pub async fn next_row_group(&mut self) -> Result<Option<ParquetRecordBatchReader>> {
655
loop {
656
+ // Take ownership of request state to process, leaving self in a
657
+ // valid state
658
let request_state = std::mem::replace(&mut self.request_state, RequestState::Done);
659
match request_state {
660
// No outstanding requests, proceed to setup next row group
0 commit comments