chore(fmt): Remove warnings [ci skip]

src/client/mod.rs

@@ -2,11 +2,7 @@ pub mod handshake;
 
 use std::{
     net::SocketAddr,
-    sync::{
-        atomic::{AtomicBool, AtomicU64},
-        Arc,
-    },
-    task::Waker,
+    sync::{atomic::AtomicU64, Arc},
     time::Duration,
 };
 
@@ -647,7 +643,7 @@ impl Client {
 
         let t = task::spawn(async move {
             loop {
-                let mut closer = closer_dispatch.lock().await;
+                let closer = closer_dispatch.lock().await;
                 select! {
                     _ = sleep(Duration::from_millis(50)).fuse() => {
                         let recv = last_recv.load(std::sync::atomic::Ordering::Relaxed);

src/connection/mod.rs

@@ -5,10 +5,7 @@ pub mod state;
 
 use std::{
     net::{IpAddr, Ipv4Addr, SocketAddr},
-    sync::{
-        atomic::{AtomicBool, AtomicU64},
-        Arc,
-    },
+    sync::{atomic::AtomicU64, Arc},
     time::Duration,
 };
 

src/notify/mod.rs

@@ -4,8 +4,6 @@ use async_std::channel::{Receiver, Sender};
 #[cfg(feature = "async_tokio")]
 use tokio::sync::mpsc::{Receiver, Sender};
 
-use crate::connection::queue::recv;
-
 /// Notify is a struct that wraps a buffer channel
 /// these channels are used to send messages to the main thread.
 #[derive(Clone)]

src/protocol/ack.rs

@@ -6,8 +6,6 @@ use std::{io::Cursor, ops::Range};
 use binary_utils::Streamable;
 use byteorder::{LittleEndian, ReadBytesExt, WriteBytesExt, BE};
 
-use crate::rakrs_debug;
-
 pub(crate) trait Ackable {
     type NackItem;
 

src/protocol/packet/offline.rs

@@ -7,7 +7,6 @@ use byteorder::WriteBytesExt;
 
 #[cfg(feature = "mcpe")]
 pub use crate::protocol::mcpe::UnconnectedPong;
-use crate::protocol::MAGIC;
 use crate::protocol::RAKNET_HEADER_OVERHEAD;
 
 use super::Packet;