Format code according to rustfmt

Author: hjr3

examples/client.rs

@@ -1,7 +1,7 @@
 use std::env;
 use std::time::Duration;
 
-use hyper::{Client, body::HttpBody as _};
+use hyper::{body::HttpBody as _, Client};
 use tokio::io::{self, AsyncWriteExt as _};
 
 use hyper::client::HttpConnector;
@@ -38,9 +38,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     while let Some(chunk) = res.body_mut().data().await {
         let chunk = chunk?;
-        io::stdout()
-            .write_all(&chunk)
-            .await?
+        io::stdout().write_all(&chunk).await?
     }
     Ok(())
 }

src/lib.rs

@@ -7,8 +7,8 @@ use tokio::io::{AsyncRead, AsyncWrite};
 use tokio::time::{timeout, Duration};
 use tokio_io_timeout::TimeoutStream;
 
-use hyper::{service::Service, Uri};
 use hyper::client::connect::{Connect, Connected, Connection};
+use hyper::{service::Service, Uri};
 
 mod stream;
 
@@ -78,7 +78,9 @@ where
         let timeout = timeout(connect_timeout, connecting);
 
         let fut = async move {
-            let connecting = timeout.await.map_err(|e| io::Error::new(io::ErrorKind::TimedOut, e))?;
+            let connecting = timeout
+                .await
+                .map_err(|e| io::Error::new(io::ErrorKind::TimedOut, e))?;
             let io = connecting.map_err(Into::into)?;
 
             let mut tm = TimeoutConnectorStream::new(TimeoutStream::new(io));
@@ -132,8 +134,8 @@ mod tests {
     use std::io;
     use std::time::Duration;
 
-    use hyper::Client;
     use hyper::client::HttpConnector;
+    use hyper::Client;
 
     use super::TimeoutConnector;
 

src/stream.rs

@@ -2,7 +2,7 @@ use std::io;
 use std::io::IoSlice;
 use std::pin::Pin;
 use std::task::{Context, Poll};
-use std::time::{Duration};
+use std::time::Duration;
 
 use hyper::client::connect::{Connected, Connection};
 use pin_project_lite::pin_project;