Refactor: fix Clippy lints and format code

Author: nurmohammed840

example/Cargo.toml

@@ -43,10 +43,6 @@ path = "basic.rs"
 name = "chat"
 path = "chat.rs"
 
-[[example]]
-name = "connect"
-path = "connect.rs"
-
 [[example]]
 name = "echo-udp"
 path = "echo-udp.rs"
@@ -75,34 +71,10 @@ path = "tinydb.rs"
 name = "udp-client"
 path = "udp-client.rs"
 
-[[example]]
-name = "udp-codec"
-path = "udp-codec.rs"
-
 [[example]]
 name = "tinyhttp"
 path = "tinyhttp.rs"
 
-[[example]]
-name = "custom-executor"
-path = "custom-executor.rs"
-
-[[example]]
-name = "custom-executor-tokio-context"
-path = "custom-executor-tokio-context.rs"
-
-[[example]]
-name = "named-pipe"
-path = "named-pipe.rs"
-
-[[example]]
-name = "named-pipe-ready"
-path = "named-pipe-ready.rs"
-
-[[example]]
-name = "named-pipe-multi-client"
-path = "named-pipe-multi-client.rs"
-
 [[example]]
 name = "hyper-server"
 path = "hyper-server/main.rs"

example/basic.rs

@@ -6,7 +6,7 @@ use tokio::io::{AsyncReadExt, AsyncWriteExt};
 async fn main() -> io::Result<()> {
     let listener = TcpListener::bind("127.0.0.1:8080").await?;
     println!("{listener:#?}");
-    
+
     loop {
         let (mut stream, addr) = listener.accept().await?;
         println!("[INCOMING] {addr:?}");

example/proxy.rs

@@ -22,8 +22,8 @@
 
 #![warn(rust_2018_idioms)]
 
-use tokio::io::copy_bidirectional;
 use nio::net::{TcpListener, TcpStream};
+use tokio::io::copy_bidirectional;
 
 use futures::FutureExt;
 use std::env;

src/fs/copy.rs

@@ -17,7 +17,6 @@ use std::path::Path;
 /// # Ok(())
 /// # }
 /// ```
-
 pub async fn copy(from: impl AsRef<Path>, to: impl AsRef<Path>) -> Result<u64, std::io::Error> {
     let from = from.as_ref().to_owned();
     let to = to.as_ref().to_owned();

src/fs/mod.rs

@@ -240,9 +240,6 @@ where
 {
     match crate::task::spawn_blocking(f).await {
         Ok(res) => res,
-        Err(_) => Err(io::Error::new(
-            io::ErrorKind::Other,
-            "background task failed",
-        )),
+        Err(_) => Err(io::Error::other("background task failed")),
     }
 }

src/io/scheduled_io.rs

@@ -65,7 +65,7 @@ impl Event {
         let _ = self.readiness.fetch_update(AcqRel, Acquire, |state| {
             let mut state = ReadinessVersion::from_usize(state);
             state.version = state.version.wrapping_add(1);
-            state.readiness = state.readiness | readiness;
+            state.readiness |= readiness;
             Some(state.into_usize())
         });
         self.waker.wake();

src/macros/cfg.rs

@@ -37,7 +37,6 @@ macro_rules! cfg_unix {
     }
 }
 
-
 macro_rules! cfg_aio {
     ($($item:item)*) => {
         $(

src/runtime/task/error.rs

@@ -157,13 +157,10 @@ impl fmt::Debug for JoinError {
 
 impl From<JoinError> for io::Error {
     fn from(src: JoinError) -> io::Error {
-        io::Error::new(
-            io::ErrorKind::Other,
-            match src.repr {
-                Repr::Cancelled => "task was cancelled",
-                Repr::Panic(_) => "task panicked",
-            },
-        )
+        io::Error::other(match src.repr {
+            Repr::Cancelled => "task was cancelled",
+            Repr::Panic(_) => "task panicked",
+        })
     }
 }
 

src/time/mod.rs

@@ -4,6 +4,6 @@ mod timeout;
 pub(crate) mod timer;
 
 pub use error::TimeoutError;
+pub use std::time::Duration;
 pub use timeout::{timeout, Timeout};
 pub use timer::{sleep, Sleep};
-pub use std::time::Duration;

src/time/timer.rs

@@ -36,7 +36,7 @@ impl PartialEq for Timer {
 }
 impl PartialOrd for Timer {
     fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
-        Some(other.deadline.cmp(&self.deadline))
+        Some(self.cmp(other))
     }
 }
 impl Ord for Timer {