regenerate all APIs and CLIs (#357)

gen/cloudfunctions1/src/client.rs

@@ -1,6 +1,7 @@
 // COPY OF 'src/rust/api/client.rs'
 // DO NOT EDIT
 use std::error;
+use std::error::Error as StdError;
 use std::fmt::{self, Display};
 use std::io::{self, Cursor, Read, Seek, SeekFrom, Write};
 use std::str::FromStr;
@@ -9,7 +10,10 @@ use std::time::Duration;
 
 use itertools::Itertools;
 
+use hyper::http::Uri;
+
 use hyper::body::Buf;
+use hyper::client::connect;
 use hyper::header::{HeaderMap, AUTHORIZATION, CONTENT_LENGTH, CONTENT_TYPE, USER_AGENT};
 use hyper::Method;
 use hyper::StatusCode;
@@ -18,6 +22,9 @@ use mime::{Attr, Mime, SubLevel, TopLevel, Value};
 
 use serde_json as json;
 
+use tokio::io::{AsyncRead, AsyncWrite};
+use tower_service;
+
 const LINE_ENDING: &str = "\r\n";
 
 pub enum Retry {
@@ -566,9 +573,15 @@ impl RangeResponseHeader {
 }
 
 /// A utility type to perform a resumable upload from start to end.
-pub struct ResumableUploadHelper<'a, A: 'a> {
+pub struct ResumableUploadHelper<'a, A: 'a, S>
+where
+    S: tower_service::Service<Uri> + Clone + Send + Sync + 'static,
+    S::Response: hyper::client::connect::Connection + AsyncRead + AsyncWrite + Send + Unpin + 'static,
+    S::Future: Send + Unpin + 'static,
+    S::Error: Into<Box<dyn StdError + Send + Sync>>,
+{
     pub client: &'a hyper::client::Client<
-        hyper_rustls::HttpsConnector<hyper::client::connect::HttpConnector>,
+        S,
         hyper::body::Body,
     >,
     pub delegate: &'a mut dyn Delegate,
@@ -582,7 +595,13 @@ pub struct ResumableUploadHelper<'a, A: 'a> {
     pub content_length: u64,
 }
 
-impl<'a, A> ResumableUploadHelper<'a, A> {
+impl<'a, A, S> ResumableUploadHelper<'a, A, S>
+where
+    S: tower_service::Service<Uri> + Clone + Send + Sync + 'static,
+    S::Response: hyper::client::connect::Connection + AsyncRead + AsyncWrite + Send + Unpin + 'static,
+    S::Future: Send + Unpin + 'static,
+    S::Error: Into<Box<dyn StdError + Send + Sync>>,
+{
     async fn query_transfer_status(
         &mut self,
     ) -> std::result::Result<u64, hyper::Result<hyper::Response<hyper::body::Body>>> {
@@ -697,14 +716,11 @@ impl<'a, A> ResumableUploadHelper<'a, A> {
                     }
 
                     let (res_parts, res_body) = res.into_parts();
-                    let res_body_string: String = String::from_utf8(
-                        hyper::body::to_bytes(res_body)
-                            .await
-                            .unwrap()
-                            .into_iter()
-                            .collect(),
-                    )
-                    .unwrap();
+                    let res_body = match hyper::body::to_bytes(res_body).await {
+                        Ok(res_body) => res_body.into_iter().collect(),
+                        Err(err) => return Some(Err(err)),
+                    };
+                    let res_body_string: String = String::from_utf8(res_body).unwrap();
                     let reconstructed_result =
                         hyper::Response::from_parts(res_parts, res_body_string.clone().into());