cargo fmt

src/bot/download.rs

@@ -1,17 +1,12 @@
 use reqwest::r#async::Chunk;
-use tokio::{
+use tokio::{io::AsyncWrite, stream::Stream};
-    io::AsyncWrite,
-    stream::Stream,
-};
-
 
 use crate::{
-    DownloadError,
     bot::Bot,
     network::{download_file, download_file_stream},
+    DownloadError,
 };
 
-
 impl Bot {
     /// Download file from telegram into `destination`.
     /// `path` can be obtained from [`get_file`] method.

src/network/download.rs

@@ -1,23 +1,22 @@
-use reqwest::r#async::{Client, Chunk};
+use reqwest::r#async::{Chunk, Client};
 use tokio::{
-    stream::Stream,
     io::{AsyncWrite, AsyncWriteExt},
+    stream::Stream,
 };
 
 use crate::{
+    network::{file_url, TELEGRAM_API_URL},
     DownloadError,
-    network::{TELEGRAM_API_URL, file_url},
 };
 
-
 pub async fn download_file<D>(
     client: &Client,
     token: &str,
     path: &str,
     destination: &mut D,
 ) -> Result<(), DownloadError>
-    where
+where
-        D: AsyncWrite + Unpin,
+    D: AsyncWrite + Unpin,
 {
     let mut stream = download_file_stream(client, token, path).await?;
 
@@ -36,4 +35,4 @@ pub(crate) async fn download_file_stream(
     let url = file_url(TELEGRAM_API_URL, token, path);
     let resp = client.get(&url).send().await?.error_for_status()?;
     Ok(resp.into_body())
-}
+}

src/network/request.rs

@@ -1,22 +1,22 @@
-use serde::{de::DeserializeOwned, Serialize};
-use reqwest::r#async::{
-    Client, multipart::Form, Response,
-};
 use apply::Apply;
+use reqwest::r#async::{multipart::Form, Client, Response};
+use serde::{de::DeserializeOwned, Serialize};
 
 use crate::{
-    RequestError,
-    requests::ResponseResult,
     network::{method_url, TELEGRAM_API_URL},
+    requests::ResponseResult,
+    RequestError,
 };
 
-
 pub async fn request_multipart<T>(
     client: &Client,
     token: &str,
     method_name: &str,
     params: Option<Form>,
-) -> ResponseResult<T> where T: DeserializeOwned {
+) -> ResponseResult<T>
+where
+    T: DeserializeOwned,
+{
     process_response(
         client
             .post(&method_url(TELEGRAM_API_URL, token, method_name))
@@ -28,7 +28,7 @@ pub async fn request_multipart<T>(
             .await
             .map_err(RequestError::NetworkError)?,
     )
-        .await
+    .await
 }
 
 pub async fn request_json<T: DeserializeOwned, P: Serialize>(
@@ -45,7 +45,7 @@ pub async fn request_json<T: DeserializeOwned, P: Serialize>(
             .await
             .map_err(RequestError::NetworkError)?,
     )
-        .await
+    .await
 }
 
 async fn process_response<T: DeserializeOwned>(
@@ -54,7 +54,7 @@ async fn process_response<T: DeserializeOwned>(
     let response = serde_json::from_str::<TelegramResponse<T>>(
         &response.text().await.map_err(RequestError::NetworkError)?,
     )
-        .map_err(RequestError::InvalidJson)?;
+    .map_err(RequestError::InvalidJson)?;
 
     response.into()
 }

src/requests/edit_message_live_location.rs

@@ -1,6 +1,8 @@
 use crate::{
     network,
-    requests::{ChatId, Request, RequestContext, RequestFuture, ResponseResult},
+    requests::{
+        ChatId, Request, RequestContext, RequestFuture, ResponseResult,
+    },
     types::{Message, ReplyMarkup},
 };
 

src/requests/get_chat.rs

@@ -1,23 +1,24 @@
 use crate::{
     network,
+    requests::{
+        ChatId, Request, RequestContext, RequestFuture, ResponseResult,
+    },
     types::Chat,
-    requests::{ChatId, RequestContext, RequestFuture, ResponseResult, Request},
 };
 
-/// Use this method to get up to date information about the chat 
+/// Use this method to get up to date information about the chat
-/// (current name of the user for one-on-one conversations, 
+/// (current name of the user for one-on-one conversations,
-/// current username of a user, group or channel, etc.). 
+/// current username of a user, group or channel, etc.).
 /// Returns a Chat object on success.
 #[derive(Debug, Clone, Serialize)]
 pub struct GetChat<'a> {
     #[serde(skip_serializing)]
     ctx: RequestContext<'a>,
-    /// Unique identifier for the target chat or username 
+    /// Unique identifier for the target chat or username
     /// of the target supergroup or channel (in the format @channelusername)
     chat_id: ChatId,
 }
 
-
 impl<'a> Request<'a> for GetChat<'a> {
     type ReturnValue = Chat;
 
@@ -28,16 +29,16 @@ impl<'a> Request<'a> for GetChat<'a> {
                 &self.ctx.token,
                 "getChat",
                 &self,
-            ).await
+            )
+            .await
         })
     }
 }
 
-
+impl<'a> GetChat<'a> {
-impl<'a> GetChat<'a>{
     pub fn chat_id<T>(mut self, chat_id: T) -> Self
-        where
+    where
-            T: Into<ChatId>,
+        T: Into<ChatId>,
     {
         self.chat_id = chat_id.into();
         self

src/requests/get_file.rs

@@ -4,7 +4,6 @@ use crate::{
     types::File,
 };
 
-
 /// Use this method to get basic info about a file and prepare it for
 /// downloading. For the moment, bots can download files of up to 20MB in size.
 /// On success, a File object is returned.

src/requests/send_audio.rs

@@ -1,7 +1,8 @@
 use crate::{
     network,
     requests::{
-        form_builder::FormBuilder, ChatId, Request, RequestContext, RequestFuture, ResponseResult,
+        form_builder::FormBuilder, ChatId, Request, RequestContext,
+        RequestFuture, ResponseResult,
     },
     types::{InputFile, Message, ParseMode, ReplyMarkup},
 };

src/requests/send_chat_action.rs

@@ -2,7 +2,7 @@ use crate::{
     network,
     requests::{
         ChatId, Request, RequestContext, RequestFuture, ResponseResult,
-    }
+    },
 };
 
 ///Use this method when you need to tell the user that something is happening

src/requests/send_contact.rs

@@ -1,10 +1,11 @@
 use crate::{
     network,
-    requests::{ChatId, Request, RequestContext, RequestFuture, ResponseResult},
+    requests::{
+        ChatId, Request, RequestContext, RequestFuture, ResponseResult,
+    },
     types::{Message, ReplyMarkup},
 };
 
-
 /// Use this method to send phone contacts.
 /// returned.
 #[derive(Debug, Clone, Serialize)]

src/requests/send_media_group.rs

@@ -9,7 +9,6 @@ use crate::{
     types::{InputFile, InputMedia, Message},
 };
 
-
 /// Use this method to send a group of photos or videos as an album.
 #[derive(Debug, Clone)]
 pub struct SendMediaGroup<'a> {

src/requests/send_poll.rs

@@ -1,10 +1,11 @@
 use crate::{
     network,
-    requests::{ChatId, Request, RequestContext, RequestFuture, ResponseResult},
+    requests::{
+        ChatId, Request, RequestContext, RequestFuture, ResponseResult,
+    },
     types::{Message, ReplyMarkup},
 };
 
-
 /// Use this method to send a native poll. A native poll can't be sent to a
 /// private chat. On success, the sent Message is returned.
 #[derive(Debug, Clone, Serialize)]

src/requests/send_venue.rs

@@ -1,10 +1,11 @@
 use crate::{
     network,
-    requests::{ChatId, Request, RequestContext, RequestFuture, ResponseResult},
+    requests::{
+        ChatId, Request, RequestContext, RequestFuture, ResponseResult,
+    },
     types::{Message, ReplyMarkup},
 };
 
-
 /// Use this method to send information about a venue.
 /// Message is returned.
 #[derive(Debug, Clone, Serialize)]

src/types/callback_game.rs

@@ -1,2 +1,2 @@
 /// A placeholder, currently holds no information. Use [BotFather](https://t.me/botfather) to set up your game.
-pub struct CallbackGame;
+pub struct CallbackGame;

src/types/login_url.rs

@@ -7,4 +7,4 @@ pub struct LoginUrl {
     pub bot_username: Option<String>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub request_write_access: Option<bool>,
-}
+}