fix(driver): use flume instead of crossbeam (#479)

Co-authored-by: Pop <[email protected]>

Author: Berrysoft

Cargo.toml

@@ -40,12 +40,11 @@ compio-process = { path = "./compio-process", version = "0.6.0" }
 compio-quic = { path = "./compio-quic", version = "0.5.0", default-features = false }
 
 bytes = "1.7.1"
-flume = "0.11.0"
 cfg_aliases = "0.2.1"
 cfg-if = "1.0.0"
 criterion = "0.7.0"
-crossbeam-channel = "0.5.8"
 crossbeam-queue = "0.3.8"
+flume = { version = "0.11.0", default-features = false }
 futures-channel = "0.3.29"
 futures-util = "0.3.29"
 libc = "0.2.164"

compio-dispatcher/Cargo.toml

@@ -19,7 +19,7 @@ rustdoc-args = ["--cfg", "docsrs"]
 compio-driver = { workspace = true }
 compio-runtime = { workspace = true }
 
-flume = { workspace = true }
+flume = { workspace = true, default-features = false, features = ["async"] }
 futures-channel = { workspace = true }
 
 [dev-dependencies]

compio-driver/Cargo.toml

@@ -34,7 +34,7 @@ compio-log = { workspace = true }
 
 # Utils
 cfg-if = { workspace = true }
-crossbeam-channel = { workspace = true }
+flume = { workspace = true, default-features = false }
 futures-util = { workspace = true }
 socket2 = { workspace = true, features = ["all"] }
 
@@ -67,7 +67,6 @@ slab = { workspace = true, optional = true }
 polling = "3.3.0"
 
 [target.'cfg(unix)'.dependencies]
-crossbeam-channel = { workspace = true }
 crossbeam-queue = { workspace = true }
 libc = { workspace = true }
 

compio-driver/src/asyncify.rs

@@ -7,7 +7,7 @@ use std::{
     time::Duration,
 };
 
-use crossbeam_channel::{Receiver, Sender, TrySendError, bounded};
+use flume::{Receiver, Sender, TrySendError, bounded};
 
 /// An error that may be emitted when all worker threads are busy. It simply
 /// returns the dispatchable value with a convenient [`fmt::Debug`] and

compio-quic/Cargo.toml

@@ -31,7 +31,7 @@ h3 = { version = "0.0.8", optional = true }
 h3-datagram = { version = "0.0.2", optional = true }
 
 # Utils
-flume = { workspace = true }
+flume = { workspace = true, default-features = false, features = ["async"] }
 futures-util = { workspace = true }
 thiserror = { workspace = true }
 rustc-hash = "2.0.0"