cargo fmt

Author: Drevoed

src/io/buf_writer.rs

@@ -1,9 +1,9 @@
+use crate::io::Write;
 use crate::task::{Context, Poll};
 use futures::{ready, AsyncWrite, Future, Stream};
+use std::fmt;
 use std::io::{self, IntoInnerError};
 use std::pin::Pin;
-use std::fmt;
-use crate::io::Write;
 
 const DEFAULT_CAPACITY: usize = 8 * 1024;
 
@@ -222,7 +222,7 @@ impl<W: AsyncWrite + Unpin> BufWriter<W> {
         let Self {
             inner,
             buf,
-            written
+            written,
         } = Pin::get_mut(self);
         let mut inner = Pin::new(inner);
         let len = buf.len();
@@ -284,10 +284,7 @@ impl<W: AsyncWrite + fmt::Debug + Unpin> fmt::Debug for BufWriter<W> {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         f.debug_struct("BufReader")
             .field("writer", &self.inner)
-            .field(
-                "buf",
-                &self.buf
-            )
+            .field("buf", &self.buf)
             .finish()
     }
 }
@@ -357,24 +354,28 @@ impl<W: AsyncWrite + Unpin> LineWriter<W> {
 }
 
 impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<W> {
-    fn poll_write(mut self: Pin<&mut Self>, cx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> {
+    fn poll_write(
+        mut self: Pin<&mut Self>,
+        cx: &mut Context,
+        buf: &[u8],
+    ) -> Poll<io::Result<usize>> {
         if self.need_flush {
             self.as_mut().poll_flush(cx)?;
         }
 
         let i = match memchr::memrchr(b'\n', buf) {
             Some(i) => i,
-            None => return self.as_mut().inner().as_mut().poll_write(cx, buf)
+            None => return self.as_mut().inner().as_mut().poll_write(cx, buf),
         };
 
         let n = ready!(self.as_mut().inner().as_mut().poll_write(cx, &buf[..=i])?);
         *self.as_mut().need_flush() = true;
         if ready!(self.as_mut().poll_flush(cx)).is_err() || n != i + 1 {
-            return Poll::Ready(Ok(n))
+            return Poll::Ready(Ok(n));
         }
         match ready!(self.inner().poll_write(cx, &buf[i + 1..])) {
             Ok(i) => Poll::Ready(Ok(n + 1)),
-            Err(_) => Poll::Ready(Ok(n))
+            Err(_) => Poll::Ready(Ok(n)),
         }
     }
 
@@ -390,21 +391,25 @@ impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<W> {
     }
 }
 
-impl<W: AsyncWrite + Unpin> fmt::Debug for LineWriter<W> where W: fmt::Debug {
+impl<W: AsyncWrite + Unpin> fmt::Debug for LineWriter<W>
+where
+    W: fmt::Debug,
+{
     fn fmt(&self, fmt: &mut fmt::Formatter<'_>) -> fmt::Result {
         fmt.debug_struct("LineWriter")
             .field("writer", &self.inner.inner)
-            .field("buffer",
-                   &format_args!("{}/{}", self.inner.buf.len(), self.inner.buf.capacity()))
+            .field(
+                "buffer",
+                &format_args!("{}/{}", self.inner.buf.len(), self.inner.buf.capacity()),
+            )
             .finish()
     }
 }
 
-
 mod tests {
+    use super::LineWriter;
     use crate::prelude::*;
     use crate::task;
-    use super::LineWriter;
 
     #[test]
     fn test_line_buffer() {
@@ -424,4 +429,4 @@ mod tests {
             assert_eq!(*writer.get_ref(), [0, 1, 0, b'\n', 1, b'\n', 2, 3, b'\n']);
         })
     }
-}
+}