Cargo fmt again

src/proactor.rs

@@ -1,10 +1,9 @@
-
 use std::task::{Context, Poll};
 use std::time::Duration;
 use std::{future::Future, io};
 
 use crate::config::NucleiConfig;
-use once_cell::sync::{OnceCell};
+use once_cell::sync::OnceCell;
 
 use super::syscore::*;
 use super::waker::*;

src/syscore/linux/iouring/fs/mod.rs

@@ -2,6 +2,4 @@ pub(crate) mod buffer;
 pub(crate) mod cancellation;
 pub(crate) mod store_file;
 
-
-
 pub(crate) use store_file::*;

src/syscore/linux/iouring/fs/store_file.rs

@@ -1,5 +1,3 @@
-
-
 use std::fs::File;
 use std::io;
 use std::os::unix::io::{FromRawFd, RawFd};
@@ -10,8 +8,6 @@ use super::buffer::Buffer;
 use crate::syscore::Processor;
 use lever::sync::atomics::AtomicBox;
 
-
-
 pub struct StoreFile {
     fd: RawFd,
     buf: Buffer,

src/syscore/linux/iouring/iouring.rs

@@ -6,7 +6,7 @@ use pin_utils::unsafe_pinned;
 use std::future::Future;
 
 use std::io;
-use std::os::unix::io::{AsRawFd};
+use std::os::unix::io::AsRawFd;
 use std::pin::Pin;
 use std::sync::atomic::{AtomicU64, Ordering};
 use std::task::{Context, Poll};

src/syscore/linux/iouring/mod.rs

@@ -7,7 +7,6 @@ mod processor;
 pub(crate) use fs::*;
 pub(crate) use iouring::*;
 
-
 pub(crate) use processor::*;
 
 pub const BACKEND: crate::sys::IoBackend = crate::sys::IoBackend::IoUring;

src/syscore/linux/iouring/net/multishot.rs

@@ -3,7 +3,7 @@ use crate::{Handle, Proactor};
 use crossbeam_channel::RecvError;
 use futures::Stream;
 use pin_project_lite::pin_project;
-use rustix::io_uring::{SocketFlags};
+use rustix::io_uring::SocketFlags;
 use rustix_uring::{opcode as OP, types::Fd};
 use std::io;
 use std::net::TcpStream;

src/syscore/linux/iouring/nethandle.rs

@@ -1,4 +1,3 @@
-
 use std::io;
 use std::marker::Unpin;
 use std::net::{SocketAddr, ToSocketAddrs};
@@ -17,8 +16,7 @@ use super::Processor;
 use crate::syscore::linux::iouring::fs::store_file::StoreFile;
 use crate::syscore::linux::iouring::net::multishot::TcpStreamGenerator;
 
-use crate::{Handle};
-
+use crate::Handle;
 
 impl<T: AsRawFd> Handle<T> {
     pub fn new(io: T) -> io::Result<Handle<T>> {

src/syscore/linux/iouring/processor.rs

@@ -1,14 +1,12 @@
 use std::future::Future;
 
+use std::io;
 use std::net::TcpStream;
 use std::net::{Ipv4Addr, Ipv6Addr, SocketAddrV4, SocketAddrV6, UdpSocket};
 use std::net::{SocketAddr, ToSocketAddrs};
+use std::os::unix::io::{AsRawFd, FromRawFd};
 use std::os::unix::net::{SocketAddr as UnixSocketAddr, UnixStream};
 use std::path::Path;
-use std::{
-    os::unix::io::{AsRawFd, FromRawFd},
-};
-use std::{io};
 
 use crate::proactor::Proactor;
 
@@ -17,12 +15,9 @@ use crate::Handle;
 use libc::sockaddr_un;
 use os_socketaddr::OsSocketAddr;
 
-use rustix::io_uring::{
-    msghdr, IoringRecvFlags, RecvFlags, SendFlags, SocketFlags,
-};
+use rustix::io_uring::{msghdr, IoringRecvFlags, RecvFlags, SendFlags, SocketFlags};
 use rustix::net::{SocketAddrAny, SocketAddrUnix};
 
-
 use rustix_uring::types::{socklen_t, AtFlags, Mode, OFlags, Statx, StatxFlags};
 use rustix_uring::{opcode as OP, types::Fd};
 use socket2::SockAddr;