clippy

src/crypto/decoder.rs

@@ -134,7 +134,7 @@ impl<E> Stream for Decoder<E> {
     type Item = Result<Bytes, E>;
 
     fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
-        let mut decoder = self.get_mut();
+        let decoder = self.get_mut();
 
         match Pin::new(decoder.inner.as_mut()).poll_next(cx) {
             Poll::Pending => {

src/crypto/encoder.rs

@@ -112,7 +112,7 @@ impl<E> Stream for Encoder<E> {
     type Item = Result<Bytes, E>;
 
     fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
-        let mut encoder = self.get_mut();
+        let encoder = self.get_mut();
 
         match Pin::new(encoder.inner.as_mut()).poll_next(cx) {
             Poll::Pending => {

src/http/handlers/forward.rs

@@ -71,7 +71,7 @@ pub async fn forward(
         let (output_sha256, length) = buffer.sha256_and_len();
         input_etag = Some(encrypted_stream.input_md5());
 
-        let stream_to_send = buffer.to_stream().await;
+        let stream_to_send = buffer.as_stream().await;
 
         sign_request(
             forwarded_req,

src/http/utils/memory_or_file_buffer.rs

@@ -61,7 +61,7 @@ impl MemoryOrFileBuffer {
         }
     }
 
-    pub async fn to_stream(
+    pub async fn as_stream(
         &mut self,
     ) -> Box<dyn Stream<Item = Result<bytes::Bytes, Error>> + Unpin> {
         match &mut self.file {

src/http/utils/partial_extractor.rs

@@ -30,7 +30,7 @@ impl<E> Stream for PartialExtractor<E> {
     type Item = Result<Bytes, E>;
 
     fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
-        let mut extractor = self.get_mut();
+        let extractor = self.get_mut();
 
         match Pin::new(extractor.inner.as_mut()).poll_next(cx) {
             Poll::Ready(Some(Ok(mut bytes))) => {

tests/concurrent_uploads.rs

@@ -1,6 +1,5 @@
 use assert_fs::prelude::*;
 use ds_proxy::crypto::header::*;
-use serial_test::serial;
 use std::sync::{Arc, Mutex};
 use std::thread;
 use std::time::Duration;

tests/content_length_and_transfert_encoding.rs

@@ -1,5 +1,4 @@
 use ds_proxy::crypto::header::*;
-use serial_test::serial;
 use sodiumoxide::crypto::secretstream::xchacha20poly1305::{ABYTES, HEADERBYTES};
 use std::fs::File;
 use std::io::Write;

tests/download_witness_file.rs

@@ -1,5 +1,3 @@
-use serial_test::serial;
-
 mod helpers;
 pub use helpers::*;
 

tests/keyring.rs

@@ -2,7 +2,6 @@ use std::convert::TryInto;
 
 use assert_fs::prelude::*;
 use ds_proxy::crypto::header;
-use serial_test::serial;
 
 mod helpers;
 pub use helpers::*;

tests/ping.rs

@@ -1,4 +1,3 @@
-use serial_test::serial;
 use std::fs::File;
 use std::{thread, time};
 

tests/traversal_attack.rs

@@ -1,5 +1,3 @@
-use serial_test::serial;
-
 mod helpers;
 pub use helpers::*;
 

tests/upload_and_download.rs

@@ -1,6 +1,5 @@
 use assert_fs::prelude::*;
 use ds_proxy::crypto::header::*;
-use serial_test::serial;
 
 mod helpers;
 pub use helpers::*;