Skip to content

Commit 6a08119

Browse files
committed
pager: tiny preparatory refactor
This makes the next commit cleaner.
1 parent 67d7dc6 commit 6a08119

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

scylla/src/client/pager.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -641,8 +641,10 @@ where
641641
async fn do_work(&mut self) -> Result<PageSendAttemptedProof, RequestAttemptError> {
642642
let mut paging_state = PagingState::start();
643643
loop {
644-
let result = (self.fetcher)(paging_state).await?;
645-
let response = result.into_non_error_query_response()?;
644+
let response = (self.fetcher)(paging_state)
645+
.await
646+
.and_then(QueryResponse::into_non_error_query_response)?;
647+
646648
match response.response {
647649
NonErrorResponse::Result(result::Result::Rows((rows, paging_state_response))) => {
648650
let (proof, send_result) = self

0 commit comments

Comments
 (0)