Fix clippy/fmt failures

Author: jsudano

async-nats/src/client.rs

@@ -647,7 +647,10 @@ impl Client {
     ///
     /// # // existing subscriptions are closed and further commands will fail
     /// assert!(subscription.next().await.is_none());
-    /// client.subscribe().await.expect_err("Expected further commands to fail");
+    /// client
+    ///     .subscribe()
+    ///     .await
+    ///     .expect_err("Expected further commands to fail");
     ///
     /// # Ok(())
     /// # }

async-nats/src/lib.rs

@@ -651,7 +651,7 @@ impl ConnectionHandler {
                     debug!("reconnected");
                 }
                 ExitReason::Closed => {
-                    //
+                    // Safe to ignore result as we're shutting down anyway
                     self.connector.events_tx.try_send(Event::Closed).ok();
                     break;
                 }

async-nats/tests/client_tests.rs

@@ -1131,7 +1131,7 @@ mod client {
         tokio::time::sleep(Duration::from_millis(1)).await;
 
         // assert the subscription stream is closed after draining
-        let sleep_fut = async move { while let Some(_) = sub.next().await {} };
+        let sleep_fut = async move { while sub.next().await.is_some() {} };
         tokio::time::timeout(Duration::from_secs(10), sleep_fut)
             .await
             .expect("Expected stream to drain within 10s");