From: Bennet Bleßmann <bb-github@t-online.de>
Date: Mon, 22 Jul 2024 22:01:58 +0000 (+0200)
Subject: run rustfmt
X-Git-Tag: v0.10.0~126^2~5
X-Git-Url: https://git.sagredo.dev/?a=commitdiff_plain;h=1eb6a883f6534bc6c1bce948943ce2fd1c0de532;p=scryer-prolog.git

run rustfmt
---

diff --git a/src/http.rs b/src/http.rs
index f301ef64..bd6ec33b 100644
--- 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 2a0b59e6..670f3204 100644
--- 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,
         }
     }