diff --git a/scylla/src/transport/session.rs b/scylla/src/transport/session.rs index 63f0d25290..41f8859dd1 100644 --- a/scylla/src/transport/session.rs +++ b/scylla/src/transport/session.rs @@ -625,7 +625,7 @@ impl Session { ) -> Result { let query = query.into(); let (result, paging_state) = self - .query_inner(&query, values, None, PagingState::start()) + .query(&query, values, None, PagingState::start()) .await?; if !paging_state.finished() { panic!("Unpaged query returned a non-empty paging state! This is a driver-side or server-side bug."); @@ -651,7 +651,7 @@ impl Session { paging_state: PagingState, ) -> Result<(QueryResult, PagingStateResponse), QueryError> { let query = query.into(); - self.query_inner(&query, values, Some(query.get_page_size()), paging_state) + self.query(&query, values, Some(query.get_page_size()), paging_state) .await } @@ -666,7 +666,7 @@ impl Session { /// * `query` - query to be performed /// * `values` - values bound to the query /// * `paging_state` - previously received paging state or [PagingState::start()] - async fn query_inner( + async fn query( &self, query: &Query, values: impl SerializeRow, @@ -1008,7 +1008,7 @@ impl Session { ) -> Result { let serialized_values = prepared.serialize_values(&values)?; let (result, paging_state) = self - .execute_inner(prepared, &serialized_values, None, PagingState::start()) + .execute(prepared, &serialized_values, None, PagingState::start()) .await?; if !paging_state.finished() { panic!("Unpaged query returned a non-empty paging state! This is a driver-side or server-side bug."); @@ -1024,7 +1024,7 @@ impl Session { ) -> Result<(QueryResult, PagingStateResponse), QueryError> { let serialized_values = prepared.serialize_values(&values)?; let page_size = prepared.get_page_size(); - self.execute_inner(prepared, &serialized_values, Some(page_size), paging_state) + self.execute(prepared, &serialized_values, Some(page_size), paging_state) .await } @@ -1034,7 +1034,7 @@ impl Session { /// * `prepared` - a statement prepared with [prepare](crate::transport::session::Session::prepare) /// * `values` - values bound to the statement /// * `paging_state` - paging state from the previous execution or [PagingState::start()] - async fn execute_inner( + async fn execute( &self, prepared: &PreparedStatement, serialized_values: &SerializedValues,