tokio: switch to async-compat

Author: Keruspe

Cargo.lock

@@ -18,7 +18,7 @@ async-global-executor = ["dep:async-global-executor"]
 async-io = ["dep:async-io", "async-global-executor?/async-io"]
 hickory-dns = ["dep:hickory-resolver", "tokio"] # hickory-dns only supports tokio as of now
 smol = ["dep:smol", "async-io"] # async-io required for implementing IoSafe
-tokio = ["dep:tokio", "dep:tokio-stream", "async-global-executor?/tokio", "hickory-resolver?/tokio"]
+tokio = ["dep:async-compat", "dep:tokio", "dep:tokio-stream", "async-global-executor?/tokio", "hickory-resolver?/tokio"]
 
 [dependencies]
 async-trait = "^0.1.89"
@@ -27,6 +27,10 @@ futures-core = "^0.3"
 futures-executor = "^0.3"
 futures-io = "^0.3"
 
+[dependencies.async-compat]
+version = "^0.2.5"
+optional = true
+
 [dependencies.async-global-executor]
 version = "^3.1"
 optional = true
@@ -56,11 +60,6 @@ features = ["net", "rt", "rt-multi-thread", "time"]
 version = "^0.1"
 optional = true
 
-[dependencies.tokio-util]
-version = "^0.7"
-default-features = false
-features = ["compat"]
-
 [dev-dependencies.tokio]
 version = "^1.47"
 features = ["macros", "rt-multi-thread"]

Cargo.toml

@@ -6,6 +6,7 @@ use crate::{
     traits::{Executor, Reactor, RuntimeKit},
     util::Task,
 };
+use async_compat::{Compat, CompatExt};
 use cfg_if::cfg_if;
 use futures_core::Stream;
 use futures_io::{AsyncRead, AsyncWrite};
@@ -23,7 +24,6 @@ use tokio::{
     runtime::{EnterGuard, Handle, Runtime as TokioRT},
 };
 use tokio_stream::{StreamExt, wrappers::IntervalStream};
-use tokio_util::compat::{Compat, TokioAsyncReadCompatExt};
 
 use task::TTask;