From 1b6d83751e150b043978b984e133a7fefbf32f2f Mon Sep 17 00:00:00 2001
From: Sachandhan Ganesh <sachan.ganesh@gmail.com>
Date: Wed, 20 Jan 2021 18:23:23 -0800
Subject: [PATCH] run cargo fmt

---
 examples/tls-echo-server/src/main.rs |  4 +---
 src/tcp/server.rs                    | 13 +++++++++----
 src/tls/server.rs                    | 13 +++++++++----
 3 files changed, 19 insertions(+), 11 deletions(-)

diff --git a/examples/tls-echo-server/src/main.rs b/examples/tls-echo-server/src/main.rs
index ef0cfef..74326af 100644
--- a/examples/tls-echo-server/src/main.rs
+++ b/examples/tls-echo-server/src/main.rs
@@ -62,9 +62,7 @@ async fn main() -> anyhow::Result<()> {
                 });
             }
 
-            None => {
-                break
-            }
+            None => break,
         }
     }
 
diff --git a/src/tcp/server.rs b/src/tcp/server.rs
index d7b0269..00c766e 100644
--- a/src/tcp/server.rs
+++ b/src/tcp/server.rs
@@ -36,18 +36,23 @@ impl Stream for TcpServer {
     fn poll_next(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         match futures::executor::block_on(self.listener.incoming().next()) {
             Some(Ok(tcp_stream)) => {
-                let peer_addr = tcp_stream.peer_addr().expect("Could not retrieve peer IP address");
+                let peer_addr = tcp_stream
+                    .peer_addr()
+                    .expect("Could not retrieve peer IP address");
                 debug!("Received connection attempt from {}", peer_addr);
 
                 Poll::Ready(Some(Connection::from(tcp_stream)))
-            },
+            }
 
             Some(Err(e)) => {
-                error!("Encountered error when trying to accept new connection {}", e);
+                error!(
+                    "Encountered error when trying to accept new connection {}",
+                    e
+                );
                 Poll::Pending
             }
 
-            None => Poll::Ready(None)
+            None => Poll::Ready(None),
         }
     }
 }
diff --git a/src/tls/server.rs b/src/tls/server.rs
index a2351f7..55647f0 100644
--- a/src/tls/server.rs
+++ b/src/tls/server.rs
@@ -57,7 +57,9 @@ impl Stream for TlsServer {
     fn poll_next(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         match futures::executor::block_on(self.listener.incoming().next()) {
             Some(Ok(tcp_stream)) => {
-                let peer_addr = tcp_stream.peer_addr().expect("Could not retrieve peer IP address");
+                let peer_addr = tcp_stream
+                    .peer_addr()
+                    .expect("Could not retrieve peer IP address");
                 debug!("Received connection attempt from {}", peer_addr);
 
                 match futures::executor::block_on(self.acceptor.accept(tcp_stream)) {
@@ -75,14 +77,17 @@ impl Stream for TlsServer {
                         Poll::Pending
                     }
                 }
-            },
+            }
 
             Some(Err(e)) => {
-                error!("Encountered error when trying to accept new connection {}", e);
+                error!(
+                    "Encountered error when trying to accept new connection {}",
+                    e
+                );
                 Poll::Pending
             }
 
-            None => Poll::Ready(None)
+            None => Poll::Ready(None),
         }
     }
 }
-- 
2.44.0