run rustfmt only on nightly

.github/workflows/ci.yml

@@ -52,6 +52,7 @@ jobs:
 
       - name: fmt
         uses: actions-rs/cargo@v1
+        if: matrix.rust == 'nightly'
         with:
           command: fmt
           args: --all -- --check

src/dispatching/dispatchers/filter/mod.rs

@@ -318,12 +318,16 @@ mod tests {
         let counter2 = &AtomicI32::new(0);
 
         let mut dp = FilterDispatcher::<Infallible, _>::new(|_| async {})
-            .message_handler(true, |_mes: Message| async move {
-                counter.fetch_add(1, Ordering::SeqCst);
+            .message_handler(true, |_mes: Message| {
+                async move {
+                    counter.fetch_add(1, Ordering::SeqCst);
+                }
             })
-            .message_handler(true, |_mes: Message| async move {
-                counter2.fetch_add(1, Ordering::SeqCst);
-                Ok::<_, Infallible>(())
+            .message_handler(true, |_mes: Message| {
+                async move {
+                    counter2.fetch_add(1, Ordering::SeqCst);
+                    Ok::<_, Infallible>(())
+                }
             });
 
         dp.dispatch(one_message_updater()).await;

src/dispatching/updater.rs

@@ -136,17 +136,19 @@ where
 }
 
 pub fn polling<'a>(bot: &'a Bot) -> impl Updater<Error = RequestError> + 'a {
-    let stream = stream::unfold((bot, 0), |(bot, mut offset)| async move {
-        let updates = match bot.get_updates().offset(offset).send().await {
-            Ok(updates) => {
-                if let Some(upd) = updates.last() {
-                    offset = upd.id + 1;
+    let stream = stream::unfold((bot, 0), |(bot, mut offset)| {
+        async move {
+            let updates = match bot.get_updates().offset(offset).send().await {
+                Ok(updates) => {
+                    if let Some(upd) = updates.last() {
+                        offset = upd.id + 1;
+                    }
+                    updates.into_iter().map(Ok).collect::<Vec<_>>()
                 }
-                updates.into_iter().map(Ok).collect::<Vec<_>>()
-            }
-            Err(err) => vec![Err(err)],
-        };
-        Some((stream::iter(updates), (bot, offset)))
+                Err(err) => vec![Err(err)],
+            };
+            Some((stream::iter(updates), (bot, offset)))
+        }
     })
     .flatten();
 

src/network/download.rs

@@ -42,11 +42,13 @@ pub async fn download_file_stream(
         .await?
         .error_for_status()?;
 
-    Ok(futures::stream::unfold(res, |mut res| async {
-        match res.chunk().await {
-            Err(err) => Some((Err(err), res)),
-            Ok(Some(c)) => Some((Ok(c), res)),
-            Ok(None) => None,
+    Ok(futures::stream::unfold(res, |mut res| {
+        async {
+            match res.chunk().await {
+                Err(err) => Some((Err(err), res)),
+                Ok(Some(c)) => Some((Ok(c), res)),
+                Ok(None) => None,
+            }
         }
     }))
 }