fix(ci): reduce clippy warnings (#382)

Author: Berrysoft

compio-buf/src/io_vec_buf.rs

@@ -1,7 +1,7 @@
 use std::ops::{Deref, DerefMut};
 
 use crate::{
-    t_alloc, IndexedIter, IoBuf, IoBufMut, IoSlice, IoSliceMut, OwnedIterator, SetBufInit,
+    IndexedIter, IoBuf, IoBufMut, IoSlice, IoSliceMut, OwnedIterator, SetBufInit, t_alloc,
 };
 
 /// A type that's either owned or borrowed. Like [`Cow`](std::rc::Cow) but

compio-dispatcher/src/lib.rs

@@ -203,9 +203,9 @@ impl Dispatcher {
         }) {
             std::thread::spawn(f.0);
         }
-        let results = rx.await.map_err(|_| {
-            io::Error::new(io::ErrorKind::Other, "the join task cancelled unexpectedly")
-        })?;
+        let results = rx
+            .await
+            .map_err(|_| io::Error::other("the join task cancelled unexpectedly"))?;
         for res in results {
             res.unwrap_or_else(|e| resume_unwind(e));
         }

compio-fs/src/utils/mod.rs

@@ -135,10 +135,7 @@ impl DirBuilder {
         match path.parent() {
             Some(p) => Box::pin(self.create_dir_all(p)).await?,
             None => {
-                return Err(io::Error::new(
-                    io::ErrorKind::Other,
-                    "failed to create whole tree",
-                ));
+                return Err(io::Error::other("failed to create whole tree"));
             }
         }
         match self.inner.create(path).await {

compio-quic/src/endpoint.rs

@@ -239,6 +239,7 @@ impl EndpointInner {
         self.respond(resp_buf, transmit);
     }
 
+    #[allow(clippy::result_large_err)]
     pub(crate) fn retry(
         &self,
         incoming: quinn_proto::Incoming,

compio-quic/src/incoming.rs

@@ -58,6 +58,7 @@ impl Incoming {
     /// address validation.
     ///
     /// Errors if `remote_address_validated()` is true.
+    #[allow(clippy::result_large_err)]
     pub fn retry(mut self) -> Result<(), RetryError> {
         let inner = self.0.take().unwrap();
         inner

compio-tls/src/adapter/mod.rs

@@ -129,7 +129,7 @@ async fn handshake_native_tls<S: AsyncRead + AsyncWrite>(
                 return Ok(TlsStream::from(s));
             }
             Err(e) => match e {
-                HandshakeError::Failure(e) => return Err(io::Error::new(io::ErrorKind::Other, e)),
+                HandshakeError::Failure(e) => return Err(io::Error::other(e)),
                 HandshakeError::WouldBlock(mut mid_stream) => {
                     if mid_stream.get_mut().flush_write_buf().await? == 0 {
                         mid_stream.get_mut().fill_read_buf().await?;
@@ -157,7 +157,7 @@ where
                 return Ok(s);
             }
             Err(e) => match e {
-                HandshakeError::Rustls(e) => return Err(io::Error::new(io::ErrorKind::Other, e)),
+                HandshakeError::Rustls(e) => return Err(io::Error::other(e)),
                 HandshakeError::System(e) => return Err(e),
                 HandshakeError::WouldBlock(mut mid_stream) => {
                     if mid_stream.get_mut().flush_write_buf().await? == 0 {

compio-tls/src/adapter/rtls.rs

@@ -102,7 +102,7 @@ impl TlsConnector {
         let conn = ClientConnection::new(
             self.0.clone(),
             ServerName::try_from(domain)
-                .map_err(|e| HandshakeError::System(io::Error::new(io::ErrorKind::Other, e)))?
+                .map_err(|e| HandshakeError::System(io::Error::other(e)))?
                 .to_owned(),
         )
         .map_err(HandshakeError::Rustls)?;

compio-tls/src/stream/rtls.rs

@@ -97,9 +97,7 @@ impl<S: io::Read> TlsStream<S> {
         loop {
             while self.conn.wants_read() {
                 self.conn.read_tls(&mut self.inner)?;
-                self.conn
-                    .process_new_packets()
-                    .map_err(|e| io::Error::new(io::ErrorKind::Other, e))?;
+                self.conn.process_new_packets().map_err(io::Error::other)?;
             }
 
             match f(self.conn.reader()) {