diff --git a/Cargo.toml b/Cargo.toml index e2c2f710..c38b15a8 100644 --- a/Cargo.toml +++ b/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" diff --git a/compio-dispatcher/Cargo.toml b/compio-dispatcher/Cargo.toml index 42956722..bcc828d6 100644 --- a/compio-dispatcher/Cargo.toml +++ b/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] diff --git a/compio-driver/Cargo.toml b/compio-driver/Cargo.toml index 60cdb40e..9f6e17b1 100644 --- a/compio-driver/Cargo.toml +++ b/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 } diff --git a/compio-driver/src/asyncify.rs b/compio-driver/src/asyncify.rs index 275e26c1..42e2ed1a 100644 --- a/compio-driver/src/asyncify.rs +++ b/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 diff --git a/compio-quic/Cargo.toml b/compio-quic/Cargo.toml index effd9a04..289ce3a3 100644 --- a/compio-quic/Cargo.toml +++ b/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"