rustfmt

tokio-util/src/compat.rs

@@ -1,10 +1,10 @@
 //! Compatibility between the `tokio::io` and `futures-io` versions of the
 //! `AsyncRead` and `AsyncWrite` traits.
+use futures_core::ready;
 use pin_project_lite::pin_project;
 use std::io;
 use std::pin::Pin;
 use std::task::{Context, Poll};
-use futures_core::ready;
 
 pin_project! {
     /// A compatibility layer that allows conversion between the
@@ -111,7 +111,11 @@ where
         buf: &mut tokio::io::ReadBuf<'_>,
     ) -> Poll<io::Result<()>> {
         let slice = buf.initialize_unfilled();
-        let n = ready!(futures_io::AsyncRead::poll_read(self.project().inner, cx, slice))?;
+        let n = ready!(futures_io::AsyncRead::poll_read(
+            self.project().inner,
+            cx,
+            slice
+        ))?;
         buf.add_filled(n);
         Poll::Ready(Ok(()))
     }
@@ -127,7 +131,11 @@ where
         slice: &mut [u8],
     ) -> Poll<io::Result<usize>> {
         let mut buf = tokio::io::ReadBuf::new(slice);
-        ready!(tokio::io::AsyncRead::poll_read(self.project().inner, cx, &mut buf))?;
+        ready!(tokio::io::AsyncRead::poll_read(
+            self.project().inner,
+            cx,
+            &mut buf
+        ))?;
         Poll::Ready(Ok(buf.filled().len()))
     }
 }