regen all APIs

gen/taskqueue1_beta2/src/api.rs

@@ -104,6 +104,7 @@ impl Default for Scope {
 /// }
 /// # }
 /// ```
+#[derive(Clone)]
 pub struct Taskqueue<> {
     client: hyper::Client<hyper_rustls::HttpsConnector<hyper::client::connect::HttpConnector>, hyper::body::Body>,
     auth: oauth2::authenticator::Authenticator<hyper_rustls::HttpsConnector<hyper::client::connect::HttpConnector>>,
@@ -120,7 +121,7 @@ impl<'a, > Taskqueue<> {
         Taskqueue {
             client,
             auth: authenticator,
-            _user_agent: "google-api-rust-client/2.0.5".to_string(),
+            _user_agent: "google-api-rust-client/2.0.8".to_string(),
             _base_url: "https://www.googleapis.com/taskqueue/v1beta2/projects/".to_string(),
             _root_url: "https://www.googleapis.com/".to_string(),
         }
@@ -134,7 +135,7 @@ impl<'a, > Taskqueue<> {
     }
 
     /// Set the user-agent header field to use in all requests to the server.
-    /// It defaults to `google-api-rust-client/2.0.5`.
+    /// It defaults to `google-api-rust-client/2.0.8`.
     ///
     /// Returns the previously set user-agent.
     pub fn user_agent(&mut self, agent_name: String) -> String {

gen/taskqueue1_beta2/src/client.rs

@@ -61,8 +61,8 @@ pub trait Part {}
 pub trait NestedType {}
 
 /// A utility to specify reader types which provide seeking capabilities too
-pub trait ReadSeek: Seek + Read {}
-impl<T: Seek + Read> ReadSeek for T {}
+pub trait ReadSeek: Seek + Read + Send {}
+impl<T: Seek + Read + Send> ReadSeek for T {}
 
 /// A trait for all types that can convert themselves into a *parts* string
 pub trait ToParts {
@@ -362,8 +362,8 @@ const BOUNDARY: &str = "MDuXWGyeE33QFXGchb2VFWc4Z7945d";
 /// to google APIs, and might not be a fully-featured implementation.
 #[derive(Default)]
 pub struct MultiPartReader<'a> {
-    raw_parts: Vec<(HeaderMap, &'a mut dyn Read)>,
-    current_part: Option<(Cursor<Vec<u8>>, &'a mut dyn Read)>,
+    raw_parts: Vec<(HeaderMap, &'a mut (dyn Read + Send))>,
+    current_part: Option<(Cursor<Vec<u8>>, &'a mut (dyn Read + Send))>,
     last_part_boundary: Option<Cursor<Vec<u8>>>,
 }
 
@@ -386,7 +386,7 @@ impl<'a> MultiPartReader<'a> {
     /// `mime`    - It will be put onto the content type
     pub fn add_part(
         &mut self,
-        reader: &'a mut dyn Read,
+        reader: &'a mut (dyn Read + Send),
         size: u64,
         mime_type: Mime,
     ) -> &mut MultiPartReader<'a> {
@@ -405,7 +405,7 @@ impl<'a> MultiPartReader<'a> {
     pub fn mime_type(&self) -> Mime {
         Mime(
             TopLevel::Multipart,
-            SubLevel::Ext("Related".to_string()),
+            SubLevel::Ext("related".to_string()),
             vec![(
                 Attr::Ext("boundary".to_string()),
                 Value::Ext(BOUNDARY.to_string()),
@@ -449,9 +449,11 @@ impl<'a> Read for MultiPartReader<'a> {
             (n, true, _) if n > 0 => {
                 let (headers, reader) = self.raw_parts.remove(0);
                 let mut c = Cursor::new(Vec::<u8>::new());
+                // TODO: The first line ending should be omitted for the first part,
+                // fortunately Google's API serves don't seem to mind.
                 (write!(
                     &mut c,
-                    "{}--{}{}{}{}",
+                    "{}--{}{}{}{}{}",
                     LINE_ENDING,
                     BOUNDARY,
                     LINE_ENDING,
@@ -459,7 +461,8 @@ impl<'a> Read for MultiPartReader<'a> {
                         .iter()
                         .map(|(k, v)| format!("{}: {}", k, v.to_str().unwrap()))
                         .join(LINE_ENDING),
-                    LINE_ENDING
+                    LINE_ENDING,
+                    LINE_ENDING,
                 ))
                 .unwrap();
                 c.seek(SeekFrom::Start(0)).unwrap();
@@ -482,7 +485,7 @@ impl<'a> Read for MultiPartReader<'a> {
                         // before clearing the last part, we will add the boundary that
                         // will be written last
                         self.last_part_boundary = Some(Cursor::new(
-                            format!("{}--{}--", LINE_ENDING, BOUNDARY).into_bytes(),
+                            format!("{}--{}--{}", LINE_ENDING, BOUNDARY, LINE_ENDING).into_bytes(),
                         ))
                     }
                     // We are depleted - this can trigger the next part to come in
@@ -696,8 +699,9 @@ impl<'a, A> ResumableUploadHelper<'a, A> {
             _ => MIN_CHUNK_SIZE,
         };
 
-        self.reader.seek(SeekFrom::Start(start)).unwrap();
         loop {
+            self.reader.seek(SeekFrom::Start(start)).unwrap();
+
             let request_size = match self.content_length - start {
                 rs if rs > chunk_size => chunk_size,
                 rs => rs,
@@ -713,7 +717,6 @@ impl<'a, A> ResumableUploadHelper<'a, A> {
                 }),
                 total_length: self.content_length,
             };
-            start += request_size;
             if self.delegate.cancel_chunk_upload(&range_header) {
                 return None;
             }
@@ -732,6 +735,8 @@ impl<'a, A> ResumableUploadHelper<'a, A> {
                 .await;
             match res {
                 Ok(res) => {
+                    start += request_size;
+
                     if res.status() == StatusCode::PERMANENT_REDIRECT {
                         continue;
                     }

gen/taskqueue1_beta2/src/lib.rs

@@ -2,7 +2,7 @@
 // This file was generated automatically from 'src/mako/api/lib.rs.mako'
 // DO NOT EDIT !
 
-//! This documentation was generated from *taskqueue* crate version *2.0.5+20160428*, where *20160428* is the exact revision of the *taskqueue:v1beta2* schema built by the [mako](http://www.makotemplates.org/) code generator *v2.0.5*.
+//! This documentation was generated from *taskqueue* crate version *2.0.8+20160428*, where *20160428* is the exact revision of the *taskqueue:v1beta2* schema built by the [mako](http://www.makotemplates.org/) code generator *v2.0.8*.
 //! 
 //! Everything else about the *taskqueue* *v1_beta2* API can be found at the
 //! [official documentation site](https://developers.google.com/appengine/docs/python/taskqueue/rest).