fmt

Author: Geal

apollo-router/src/axum_factory/compression/codec/brotli/encoder.rs

@@ -1,19 +1,21 @@
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
-use crate::axum_factory::compression::{codec::Encode, util::PartialBuffer};
-use std::{
-    fmt,
-    io::{Error, ErrorKind, Result},
-};
+use std::fmt;
+use std::io::Error;
+use std::io::ErrorKind;
+use std::io::Result;
 
-use brotli::enc::{
-    backward_references::BrotliEncoderParams,
-    encode::{
-        BrotliEncoderCompressStream, BrotliEncoderCreateInstance, BrotliEncoderHasMoreOutput,
-        BrotliEncoderIsFinished, BrotliEncoderOperation, BrotliEncoderStateStruct,
-    },
-    StandardAlloc,
-};
+use brotli::enc::backward_references::BrotliEncoderParams;
+use brotli::enc::encode::BrotliEncoderCompressStream;
+use brotli::enc::encode::BrotliEncoderCreateInstance;
+use brotli::enc::encode::BrotliEncoderHasMoreOutput;
+use brotli::enc::encode::BrotliEncoderIsFinished;
+use brotli::enc::encode::BrotliEncoderOperation;
+use brotli::enc::encode::BrotliEncoderStateStruct;
+use brotli::enc::StandardAlloc;
+
+use crate::axum_factory::compression::codec::Encode;
+use crate::axum_factory::compression::util::PartialBuffer;
 
 pub(crate) struct BrotliEncoder {
     state: BrotliEncoderStateStruct<StandardAlloc>,

apollo-router/src/axum_factory/compression/codec/deflate/encoder.rs

@@ -1,13 +1,13 @@
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
-use crate::axum_factory::compression::{
-    codec::{Encode, FlateEncoder},
-    util::PartialBuffer,
-};
 use std::io::Result;
 
 use flate2::Compression;
 
+use crate::axum_factory::compression::codec::Encode;
+use crate::axum_factory::compression::codec::FlateEncoder;
+use crate::axum_factory::compression::util::PartialBuffer;
+
 #[derive(Debug)]
 pub(crate) struct DeflateEncoder {
     inner: FlateEncoder,

apollo-router/src/axum_factory/compression/codec/flate/encoder.rs

@@ -1,10 +1,16 @@
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
-use std::io::{Error, ErrorKind, Result};
+use std::io::Error;
+use std::io::ErrorKind;
+use std::io::Result;
 
-use flate2::{Compress, Compression, FlushCompress, Status};
+use flate2::Compress;
+use flate2::Compression;
+use flate2::FlushCompress;
+use flate2::Status;
 
-use crate::axum_factory::compression::{codec::Encode, util::PartialBuffer};
+use crate::axum_factory::compression::codec::Encode;
+use crate::axum_factory::compression::util::PartialBuffer;
 
 #[derive(Debug)]
 pub(crate) struct FlateEncoder {

apollo-router/src/axum_factory/compression/codec/gzip/encoder.rs

@@ -2,9 +2,11 @@
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
 use std::io::Result;
 
-use flate2::{Compression, Crc};
+use flate2::Compression;
+use flate2::Crc;
 
-use crate::axum_factory::compression::codec::{Encode, FlateEncoder};
+use crate::axum_factory::compression::codec::Encode;
+use crate::axum_factory::compression::codec::FlateEncoder;
 use crate::axum_factory::compression::util::PartialBuffer;
 
 #[derive(Debug)]

apollo-router/src/axum_factory/compression/codec/gzip/header.rs

@@ -1,8 +1,11 @@
 #![allow(dead_code)]
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
+use std::io::Error;
+use std::io::ErrorKind;
+use std::io::Result;
+
 use crate::axum_factory::compression::util::PartialBuffer;
-use std::io::{Error, ErrorKind, Result};
 
 #[derive(Debug, Default)]
 struct Flags {

apollo-router/src/axum_factory/compression/codec/gzip/mod.rs

@@ -3,4 +3,4 @@
 mod encoder;
 mod header;
 
-pub(crate) use self::{encoder::GzipEncoder};
+pub(crate) use self::encoder::GzipEncoder;

apollo-router/src/axum_factory/compression/codec/mod.rs

@@ -1,8 +1,9 @@
 // All code from this module is extracted from https://github.com/Nemo157/async-compression and is under MIT or Apache-2 licence
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
-use super::util::PartialBuffer;
 use std::io::Result;
 
+use super::util::PartialBuffer;
+
 mod brotli;
 mod deflate;
 mod flate;

apollo-router/src/axum_factory/compression/codec/zstd/encoder.rs

@@ -2,9 +2,12 @@
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
 use std::io::Result;
 
-use zstd::stream::raw::{Encoder, Operation};
+use zstd::stream::raw::Encoder;
+use zstd::stream::raw::Operation;
 
-use crate::axum_factory::compression::{codec::Encode, unshared::Unshared, util::PartialBuffer};
+use crate::axum_factory::compression::codec::Encode;
+use crate::axum_factory::compression::unshared::Unshared;
+use crate::axum_factory::compression::util::PartialBuffer;
 
 #[derive(Debug)]
 pub(crate) struct ZstdEncoder {

apollo-router/src/axum_factory/compression/mod.rs

@@ -1,15 +1,19 @@
 use brotli::enc::BrotliEncoderParams;
-use bytes::{Bytes, BytesMut};
+use bytes::Bytes;
+use bytes::BytesMut;
 use flate2::Compression;
-use futures::{Stream, StreamExt};
+use futures::Stream;
+use futures::StreamExt;
 use tokio::sync::mpsc;
 use tokio_stream::wrappers::ReceiverStream;
 use tower::BoxError;
 
-use self::{
-    codec::{BrotliEncoder, DeflateEncoder, Encode, GzipEncoder, ZstdEncoder},
-    util::PartialBuffer,
-};
+use self::codec::BrotliEncoder;
+use self::codec::DeflateEncoder;
+use self::codec::Encode;
+use self::codec::GzipEncoder;
+use self::codec::ZstdEncoder;
+use self::util::PartialBuffer;
 
 pub(crate) mod codec;
 pub(crate) mod unshared;

apollo-router/src/axum_factory/compression/unshared.rs

@@ -2,7 +2,8 @@
 // it will be removed when we find a long lasting solution to https://github.com/Nemo157/async-compression/issues/154
 #![allow(dead_code)] // unused without any features
 
-use core::fmt::{self, Debug};
+use core::fmt::Debug;
+use core::fmt::{self};
 
 /// Wraps a type and only allows unique borrowing, the main usecase is to wrap a `!Sync` type and
 /// implement `Sync` for it as this type blocks having multiple shared references to the inner