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 ddf21d4 commit 57277c8Copy full SHA for 57277c8
scylla/src/client/pager.rs
@@ -643,8 +643,10 @@ where
643
async fn do_work(&mut self) -> Result<PageSendAttemptedProof, RequestAttemptError> {
644
let mut paging_state = PagingState::start();
645
loop {
646
- let result = (self.fetcher)(paging_state).await?;
647
- let response = result.into_non_error_query_response()?;
+ let response = (self.fetcher)(paging_state)
+ .await
648
+ .and_then(QueryResponse::into_non_error_query_response)?;
649
+
650
match response.response {
651
NonErrorResponseWithDeserializedMetadata::Result(
652
result::ResultWithDeserializedMetadata::Rows((rows, paging_state_response)),
0 commit comments