With the BigQuery paginator updates

Author: coryan

.github/workflows/generator_dart.yaml

@@ -57,7 +57,7 @@ jobs:
       # the inputs should be pinned, including the generator version and the
       # googleapis SHA.
       - name: Regenerate existing clients
-        run: go run github.com/googleapis/librarian/cmd/[email protected].20250918140618-f7a7c8e2b04e refreshall -project-root dart
+        run: go run github.com/googleapis/librarian/cmd/[email protected].20250918151329-de628ecd7aa3 refreshall -project-root dart
       - run: git diff --exit-code
 
   validate-packages:

.github/workflows/sdk.yaml

@@ -504,7 +504,7 @@ jobs:
           sudo unzip -x /tmp/protoc.zip
           protoc --version
       - name: Regenerate all the code
-        run: go run github.com/googleapis/librarian/cmd/[email protected].20250918140618-f7a7c8e2b04e refreshall
+        run: go run github.com/googleapis/librarian/cmd/[email protected].20250918151329-de628ecd7aa3 refreshall
       - run: cargo fmt
         # If there is any difference between the generated code and the
         # committed code that is an error. All the inputs should be pinned,

src/generated/cloud/bigquery/v2/src/builder.rs

@@ -558,9 +558,13 @@ pub mod dataset_service {
     /// # use google_cloud_bigquery_v2::builder;
     /// use builder::dataset_service::ListDatasets;
     /// # tokio_test::block_on(async {
+    /// use gax::paginator::ItemPaginator;
     ///
     /// let builder = prepare_request_builder();
-    /// let response = builder.send().await?;
+    /// let mut items = builder.by_item();
+    /// while let Some(result) = items.next().await {
+    ///   let item = result?;
+    /// }
     /// # gax::Result::<()>::Ok(()) });
     ///
     /// fn prepare_request_builder() -> ListDatasets {
@@ -598,6 +602,29 @@ pub mod dataset_service {
                 .map(gax::response::Response::into_body)
         }
 
+        /// Streams each page in the collection.
+        pub fn by_page(
+            self,
+        ) -> impl gax::paginator::Paginator<crate::model::DatasetList, gax::error::Error> {
+            use std::clone::Clone;
+            let token = self.0.request.page_token.clone();
+            let execute = move |token: String| {
+                let mut builder = self.clone();
+                builder.0.request = builder.0.request.set_page_token(token);
+                builder.send()
+            };
+            gax::paginator::internal::new_paginator(token, execute)
+        }
+
+        /// Streams each item in the collection.
+        pub fn by_item(
+            self,
+        ) -> impl gax::paginator::ItemPaginator<crate::model::DatasetList, gax::error::Error>
+        {
+            use gax::paginator::Paginator;
+            self.by_page().items()
+        }
+
         /// Sets the value of [project_id][crate::model::ListDatasetsRequest::project_id].
         ///
         /// This is a **required** field for requests.
@@ -1114,9 +1141,13 @@ pub mod job_service {
     /// # use google_cloud_bigquery_v2::builder;
     /// use builder::job_service::ListJobs;
     /// # tokio_test::block_on(async {
+    /// use gax::paginator::ItemPaginator;
     ///
     /// let builder = prepare_request_builder();
-    /// let response = builder.send().await?;
+    /// let mut items = builder.by_item();
+    /// while let Some(result) = items.next().await {
+    ///   let item = result?;
+    /// }
     /// # gax::Result::<()>::Ok(()) });
     ///
     /// fn prepare_request_builder() -> ListJobs {
@@ -1154,6 +1185,28 @@ pub mod job_service {
                 .map(gax::response::Response::into_body)
         }
 
+        /// Streams each page in the collection.
+        pub fn by_page(
+            self,
+        ) -> impl gax::paginator::Paginator<crate::model::JobList, gax::error::Error> {
+            use std::clone::Clone;
+            let token = self.0.request.page_token.clone();
+            let execute = move |token: String| {
+                let mut builder = self.clone();
+                builder.0.request = builder.0.request.set_page_token(token);
+                builder.send()
+            };
+            gax::paginator::internal::new_paginator(token, execute)
+        }
+
+        /// Streams each item in the collection.
+        pub fn by_item(
+            self,
+        ) -> impl gax::paginator::ItemPaginator<crate::model::JobList, gax::error::Error> {
+            use gax::paginator::Paginator;
+            self.by_page().items()
+        }
+
         /// Sets the value of [project_id][crate::model::ListJobsRequest::project_id].
         pub fn set_project_id<T: Into<std::string::String>>(mut self, v: T) -> Self {
             self.0.request.project_id = v.into();
@@ -1628,9 +1681,13 @@ pub mod model_service {
     /// # use google_cloud_bigquery_v2::builder;
     /// use builder::model_service::ListModels;
     /// # tokio_test::block_on(async {
+    /// use gax::paginator::ItemPaginator;
     ///
     /// let builder = prepare_request_builder();
-    /// let response = builder.send().await?;
+    /// let mut items = builder.by_item();
+    /// while let Some(result) = items.next().await {
+    ///   let item = result?;
+    /// }
     /// # gax::Result::<()>::Ok(()) });
     ///
     /// fn prepare_request_builder() -> ListModels {
@@ -1668,6 +1725,30 @@ pub mod model_service {
                 .map(gax::response::Response::into_body)
         }
 
+        /// Streams each page in the collection.
+        pub fn by_page(
+            self,
+        ) -> impl gax::paginator::Paginator<crate::model::ListModelsResponse, gax::error::Error>
+        {
+            use std::clone::Clone;
+            let token = self.0.request.page_token.clone();
+            let execute = move |token: String| {
+                let mut builder = self.clone();
+                builder.0.request = builder.0.request.set_page_token(token);
+                builder.send()
+            };
+            gax::paginator::internal::new_paginator(token, execute)
+        }
+
+        /// Streams each item in the collection.
+        pub fn by_item(
+            self,
+        ) -> impl gax::paginator::ItemPaginator<crate::model::ListModelsResponse, gax::error::Error>
+        {
+            use gax::paginator::Paginator;
+            self.by_page().items()
+        }
+
         /// Sets the value of [project_id][crate::model::ListModelsRequest::project_id].
         ///
         /// This is a **required** field for requests.
@@ -2437,9 +2518,13 @@ pub mod routine_service {
     /// # use google_cloud_bigquery_v2::builder;
     /// use builder::routine_service::ListRoutines;
     /// # tokio_test::block_on(async {
+    /// use gax::paginator::ItemPaginator;
     ///
     /// let builder = prepare_request_builder();
-    /// let response = builder.send().await?;
+    /// let mut items = builder.by_item();
+    /// while let Some(result) = items.next().await {
+    ///   let item = result?;
+    /// }
     /// # gax::Result::<()>::Ok(()) });
     ///
     /// fn prepare_request_builder() -> ListRoutines {
@@ -2477,6 +2562,30 @@ pub mod routine_service {
                 .map(gax::response::Response::into_body)
         }
 
+        /// Streams each page in the collection.
+        pub fn by_page(
+            self,
+        ) -> impl gax::paginator::Paginator<crate::model::ListRoutinesResponse, gax::error::Error>
+        {
+            use std::clone::Clone;
+            let token = self.0.request.page_token.clone();
+            let execute = move |token: String| {
+                let mut builder = self.clone();
+                builder.0.request = builder.0.request.set_page_token(token);
+                builder.send()
+            };
+            gax::paginator::internal::new_paginator(token, execute)
+        }
+
+        /// Streams each item in the collection.
+        pub fn by_item(
+            self,
+        ) -> impl gax::paginator::ItemPaginator<crate::model::ListRoutinesResponse, gax::error::Error>
+        {
+            use gax::paginator::Paginator;
+            self.by_page().items()
+        }
+
         /// Sets the value of [project_id][crate::model::ListRoutinesRequest::project_id].
         ///
         /// This is a **required** field for requests.
@@ -3793,9 +3902,13 @@ pub mod table_service {
     /// # use google_cloud_bigquery_v2::builder;
     /// use builder::table_service::ListTables;
     /// # tokio_test::block_on(async {
+    /// use gax::paginator::ItemPaginator;
     ///
     /// let builder = prepare_request_builder();
-    /// let response = builder.send().await?;
+    /// let mut items = builder.by_item();
+    /// while let Some(result) = items.next().await {
+    ///   let item = result?;
+    /// }
     /// # gax::Result::<()>::Ok(()) });
     ///
     /// fn prepare_request_builder() -> ListTables {
@@ -3833,6 +3946,29 @@ pub mod table_service {
                 .map(gax::response::Response::into_body)
         }
 
+        /// Streams each page in the collection.
+        pub fn by_page(
+            self,
+        ) -> impl gax::paginator::Paginator<crate::model::TableList, gax::error::Error> {
+            use std::clone::Clone;
+            let token = self.0.request.page_token.clone();
+            let execute = move |token: String| {
+                let mut builder = self.clone();
+                builder.0.request = builder.0.request.set_page_token(token);
+                builder.send()
+            };
+            gax::paginator::internal::new_paginator(token, execute)
+        }
+
+        /// Streams each item in the collection.
+        pub fn by_item(
+            self,
+        ) -> impl gax::paginator::ItemPaginator<crate::model::TableList, gax::error::Error>
+        {
+            use gax::paginator::Paginator;
+            self.by_page().items()
+        }
+
         /// Sets the value of [project_id][crate::model::ListTablesRequest::project_id].
         ///
         /// This is a **required** field for requests.

src/generated/cloud/bigquery/v2/src/model.rs

@@ -2908,6 +2908,20 @@ impl wkt::message::Message for DatasetList {
     }
 }
 
+#[doc(hidden)]
+impl gax::paginator::internal::PageableResponse for DatasetList {
+    type PageItem = crate::model::ListFormatDataset;
+
+    fn items(self) -> std::vec::Vec<Self::PageItem> {
+        self.datasets
+    }
+
+    fn next_page_token(&self) -> std::string::String {
+        use std::clone::Clone;
+        self.next_page_token.clone()
+    }
+}
+
 /// Request format for undeleting a dataset.
 #[derive(Clone, Default, PartialEq)]
 #[non_exhaustive]
@@ -6331,6 +6345,20 @@ impl wkt::message::Message for JobList {
     }
 }
 
+#[doc(hidden)]
+impl gax::paginator::internal::PageableResponse for JobList {
+    type PageItem = crate::model::ListFormatJob;
+
+    fn items(self) -> std::vec::Vec<Self::PageItem> {
+        self.jobs
+    }
+
+    fn next_page_token(&self) -> std::string::String {
+        use std::clone::Clone;
+        self.next_page_token.clone()
+    }
+}
+
 /// Request object of GetQueryResults.
 #[derive(Clone, Default, PartialEq)]
 #[non_exhaustive]
@@ -28587,6 +28615,20 @@ impl wkt::message::Message for ListModelsResponse {
     }
 }
 
+#[doc(hidden)]
+impl gax::paginator::internal::PageableResponse for ListModelsResponse {
+    type PageItem = crate::model::Model;
+
+    fn items(self) -> std::vec::Vec<Self::PageItem> {
+        self.models
+    }
+
+    fn next_page_token(&self) -> std::string::String {
+        use std::clone::Clone;
+        self.next_page_token.clone()
+    }
+}
+
 /// Id path of a model.
 #[derive(Clone, Default, PartialEq)]
 #[non_exhaustive]
@@ -32380,6 +32422,20 @@ impl wkt::message::Message for ListRoutinesResponse {
     }
 }
 
+#[doc(hidden)]
+impl gax::paginator::internal::PageableResponse for ListRoutinesResponse {
+    type PageItem = crate::model::Routine;
+
+    fn items(self) -> std::vec::Vec<Self::PageItem> {
+        self.routines
+    }
+
+    fn next_page_token(&self) -> std::string::String {
+        use std::clone::Clone;
+        self.next_page_token.clone()
+    }
+}
+
 /// Id path of a routine.
 #[derive(Clone, Default, PartialEq)]
 #[non_exhaustive]
@@ -36405,6 +36461,20 @@ impl wkt::message::Message for TableList {
     }
 }
 
+#[doc(hidden)]
+impl gax::paginator::internal::PageableResponse for TableList {
+    type PageItem = crate::model::ListFormatTable;
+
+    fn items(self) -> std::vec::Vec<Self::PageItem> {
+        self.tables
+    }
+
+    fn next_page_token(&self) -> std::string::String {
+        use std::clone::Clone;
+        self.next_page_token.clone()
+    }
+}
+
 /// Represents the primary key constraint on a table's columns.
 #[derive(Clone, Default, PartialEq)]
 #[non_exhaustive]