Remove unnecessary requirement for Sync for storage_objects_insert_ex…

…t_stream extension function (#147)
abdolence · Jul 3, 2024 · be990be · be990be
1 parent 7a447c1
commit be990be
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/gcloud-protos-generator/openapi/google/storage-v1/ext/apis/objects_api.rs b/gcloud-protos-generator/openapi/google/storage-v1/ext/apis/objects_api.rs
@@ -1,4 +1,5 @@
 pub type BoxStreamWithSync<'a, T> = std::pin::Pin<Box<dyn futures::Stream<Item = T> + Send + 'a + Sync>>;
+pub type BoxStreamWithSend<'a, T> = std::pin::Pin<Box<dyn futures::Stream<Item = T> + Send + 'a>>;
 
 /// Stores a new object and metadata.
 /// Open API doesn't support binary streams and this particular endpoint uses another base URL.
@@ -7,7 +8,7 @@ pub async fn storage_objects_insert_ext_stream(
     configuration: &configuration::Configuration,
     params: StoragePeriodObjectsPeriodInsertParams,
     content_type: Option<String>,
-    bytes_stream: BoxStreamWithSync<
+    bytes_stream: BoxStreamWithSend<
         'static,
         std::result::Result<bytes::Bytes, Box<(dyn std::error::Error + Send + Sync + 'static)>>,
     >
@@ -166,7 +167,7 @@ pub async fn storage_objects_insert_ext_bytes(
 > {
     use futures::StreamExt;
 
-    let bytes_stream: BoxStreamWithSync<
+    let bytes_stream: BoxStreamWithSend<
         'static,
         std::result::Result<bytes::Bytes, Box<(dyn std::error::Error + Send + Sync + 'static)>>,
     > = Box::pin(

diff --git a/gcloud-sdk/src/rest_apis/google_rest_apis/storage_v1/apis/objects_api.rs b/gcloud-sdk/src/rest_apis/google_rest_apis/storage_v1/apis/objects_api.rs
@@ -2381,6 +2381,7 @@ pub async fn storage_objects_watch_all(
 
 pub type BoxStreamWithSync<'a, T> =
     std::pin::Pin<Box<dyn futures::Stream<Item = T> + Send + 'a + Sync>>;
+pub type BoxStreamWithSend<'a, T> = std::pin::Pin<Box<dyn futures::Stream<Item = T> + Send + 'a>>;
 
 /// Stores a new object and metadata.
 /// Open API doesn't support binary streams and this particular endpoint uses another base URL.
@@ -2389,7 +2390,7 @@ pub async fn storage_objects_insert_ext_stream(
     configuration: &configuration::Configuration,
     params: StoragePeriodObjectsPeriodInsertParams,
     content_type: Option<String>,
-    bytes_stream: BoxStreamWithSync<
+    bytes_stream: BoxStreamWithSend<
         'static,
         std::result::Result<bytes::Bytes, Box<(dyn std::error::Error + Send + Sync + 'static)>>,
     >,
@@ -2546,7 +2547,7 @@ pub async fn storage_objects_insert_ext_bytes(
 > {
     use futures::StreamExt;
 
-    let bytes_stream: BoxStreamWithSync<
+    let bytes_stream: BoxStreamWithSend<
         'static,
         std::result::Result<bytes::Bytes, Box<(dyn std::error::Error + Send + Sync + 'static)>>,
     > = Box::pin(