run rustfmt

diff --git a/src/http.rs b/src/http.rs
index f301ef645e2b06c9cdcac4f0fb4385085739fa92..bd6ec33b3de3ca0ce287fb6e0684fb76218e6cca 100644 (file)
--- a/src/http.rs
+++ b/src/http.rs
@@ -1,4 +1,4 @@
-use bytes::{Bytes, buf::Reader};
+use bytes::{buf::Reader, Bytes};
 use std::sync::{Arc, Condvar, Mutex};
 
 use warp::http;

diff --git a/src/machine/streams.rs b/src/machine/streams.rs
index 2a0b59e6c53aa472b813bd4aa3279a5c574ba29a..670f3204d2f4bb5b08c4fa58cd00c52bf3508dbb 100644 (file)
--- a/src/machine/streams.rs
+++ b/src/machine/streams.rs
@@ -15,6 +15,8 @@ use crate::types::*;
 use bytes::Buf;
 pub use scryer_modular_bitfield::prelude::*;
 
+#[cfg(feature = "http")]
+use bytes::{buf::Reader as BufReader, Bytes};
 use std::cmp::Ordering;
 use std::error::Error;
 use std::fmt;
@@ -22,8 +24,6 @@ use std::fmt::Debug;
 use std::fs::{File, OpenOptions};
 use std::hash::Hash;
 use std::io;
-#[cfg(feature = "http")]
-use bytes::{buf::Reader as BufReader, Bytes};
 use std::io::{Cursor, ErrorKind, Read, Seek, SeekFrom, Write};
 use std::net::{Shutdown, TcpStream};
 use std::ops::{Deref, DerefMut};
@@ -1136,13 +1136,19 @@ impl Stream {
                     }
                 }
             }
-           Stream::HttpRead(stream_layout) => {
-               if stream_layout.stream.get_ref().body_reader.get_ref().has_remaining() {
-                   AtEndOfStream::Not
-               } else {
-                   AtEndOfStream::Past
-               }
-           }
+            Stream::HttpRead(stream_layout) => {
+                if stream_layout
+                    .stream
+                    .get_ref()
+                    .body_reader
+                    .get_ref()
+                    .has_remaining()
+                {
+                    AtEndOfStream::Not
+                } else {
+                    AtEndOfStream::Past
+                }
+            }
             _ => AtEndOfStream::Not,
         }
     }