diff --git a/src/net/tcp/stream.rs b/src/net/tcp/stream.rs
index e4bef93..7c10602 100644
--- a/src/net/tcp/stream.rs
+++ b/src/net/tcp/stream.rs
@@ -345,7 +345,8 @@ impl AsyncWrite for &TcpStream {
         cx: &mut Context<'_>,
         buf: &[u8],
     ) -> Poll<io::Result<usize>> {
-        self.watcher.poll_write_with(cx, |mut inner| inner.write(buf))
+        self.watcher
+            .poll_write_with(cx, |mut inner| inner.write(buf))
     }
 
     fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
diff --git a/src/os/unix/net/stream.rs b/src/os/unix/net/stream.rs
index d4e6e64..28f43eb 100644
--- a/src/os/unix/net/stream.rs
+++ b/src/os/unix/net/stream.rs
@@ -1,9 +1,9 @@
 //! Unix-specific networking extensions.
 
 use std::fmt;
+use std::io::{Read as _, Write as _};
 use std::net::Shutdown;
 use std::path::Path;
-use std::io::{Read as _, Write as _};
 use std::pin::Pin;
 
 use futures_io::{AsyncRead, AsyncWrite};
@@ -198,7 +198,8 @@ impl AsyncWrite for &UnixStream {
         cx: &mut Context<'_>,
         buf: &[u8],
     ) -> Poll<io::Result<usize>> {
-        self.watcher.poll_write_with(cx, |mut inner| inner.write(buf))
+        self.watcher
+            .poll_write_with(cx, |mut inner| inner.write(buf))
     }
 
     fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {