cargo fmt

Author: fairingrey

src/stream/gzip.rs

@@ -178,11 +178,8 @@ impl<S: Stream<Item = Result<Bytes>>> Stream for DecompressedGzipStream<S> {
 
         // reserve the last 8 bytes for when the footer is reached
         let (prior_in, prior_out) = (this.decompress.total_in(), this.decompress.total_out());
-        this.decompress.decompress(
-            this.input_buffer,
-            this.output_buffer,
-            flush,
-        )?;
+        this.decompress
+            .decompress(this.input_buffer, this.output_buffer, flush)?;
         let input = this.decompress.total_in() - prior_in;
         let output = this.decompress.total_out() - prior_out;
 

tests/gzip.rs

@@ -52,16 +52,17 @@ fn decompressed_gzip_stream_2() {
     let data: Vec<_> = block_on(decompressed.collect());
     let data: io::Result<Vec<_>> = data.into_iter().collect();
     let data: Vec<u8> = data.unwrap().into_iter().flatten().collect();
-    assert_eq!(data, vec![1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15]);
+    assert_eq!(
+        data,
+        vec![1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15]
+    );
 }
 
 #[test]
 fn decompressed_gzip_stream_3() {
     use async_compression::stream::gzip;
 
-    let stream = stream::iter(vec![
-        Bytes::from_static(&[]),
-    ]);
+    let stream = stream::iter(vec![Bytes::from_static(&[])]);
     let compressed = gzip::GzipStream::new(stream.map(Ok), gzip::Compression::default());
     let decompressed = gzip::DecompressedGzipStream::new(compressed);
     let data: Vec<_> = block_on(decompressed.collect());