Skip to content

Commit

Permalink
Removed Sync requirement for storage_objects_insert_ext_stream after …
Browse files Browse the repository at this point in the history
…Reqwest v0.12.6+
  • Loading branch information
abdolence committed Sep 10, 2024
1 parent 93f134c commit 374b86f
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ pub async fn storage_objects_insert_ext_stream<S>(
Error<StoragePeriodObjectsPeriodInsertError>,
>
where
S: futures::stream::TryStream + Send + Sync + 'static,
S: futures::stream::TryStream + Send + 'static,
S::Error: Into<Box<dyn std::error::Error + Send + Sync>>,
Bytes: From<S::Ok>,
{
Expand Down Expand Up @@ -169,7 +169,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(
Expand Down
2 changes: 1 addition & 1 deletion gcloud-sdk/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -448,7 +448,7 @@ tokio= { version = "1" }
tracing = "0.1"
secret-vault-value = { version="0.3", features=["proto", "serde"] }
once_cell = "1.19"
reqwest = { version="0.12", features=["multipart", "json", "gzip", "stream"], default-features = false }
reqwest = { version=">=0.12.7", features=["multipart", "json", "gzip", "stream"], default-features = false }
bytes = { version = "1"}
serde_with = { version = "3", optional = true }

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2397,7 +2397,7 @@ pub async fn storage_objects_insert_ext_stream<S>(
Error<StoragePeriodObjectsPeriodInsertError>,
>
where
S: futures::stream::TryStream + Send + Sync + 'static,
S: futures::stream::TryStream + Send + 'static,
S::Error: Into<Box<dyn std::error::Error + Send + Sync>>,
Bytes: From<S::Ok>,
{
Expand Down Expand Up @@ -2550,7 +2550,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(
Expand Down

0 comments on commit 374b86f

Please sign in to comment.