feat: replace futures crate with futures-util

Cargo.toml

@@ -11,16 +11,16 @@ all-features = true
 rustdoc-args = ["--cfg", "docsrs"]
 
 [dependencies]
-futures = { version = "0.3.31", default-features = false, optional = true }
+futures-util = { version = "0.3.31", default-features = false, optional = true }
 event-listener = { version = "5.4.1", default-features = false, optional = true }
 local-event = { version = "0.1.1", default-features = false, optional = true }
 see = { version = "0.1.1", optional = true }
 slab = { version = "0.4.11", optional = true }
 
 [features]
 watch = ["dep:see"]
-mutex = ["dep:futures", "dep:slab", "futures?/std"]
-waker_slot = ["dep:futures"]
+mutex = ["dep:futures-util", "dep:slab"]
+waker_slot = ["dep:futures-util"]
 event = ["dep:event-listener", "dep:local-event"]
 bilock = ["waker_slot"]
 

src/mutex/mod.rs → src/mutex.rs

@@ -1,6 +1,6 @@
 //! Async Mutex lock
 //!
-//! The implementation is copied from [`futures::lock`] with our own
+//! The implementation is copied from [`futures_util::lock`] with our own
 //! synchronization primitives.
 
 /// Multithreaded async Mutex
@@ -90,7 +90,7 @@ macro_rules! impl_mutex {
             task::{Context, Poll},
         };
 
-        use futures::future::FusedFuture;
+        use futures_util::future::FusedFuture;
         use slab::Slab;
 
         use super::*;
@@ -457,7 +457,7 @@ macro_rules! impl_mutex {
             ///
             /// ```
             /// # futures::executor::block_on(async {
-            /// use futures::lock::{Mutex, MutexGuard};
+            #[doc = concat!("use synchrony::", stringify!($sync), "::mutex::{Mutex, MutexGuard};")]
             ///
             /// let data = Mutex::new(Some("value".to_string()));
             /// {
@@ -529,7 +529,7 @@ macro_rules! impl_mutex {
             ///
             /// ```
             /// # futures::executor::block_on(async {
-            /// use futures::lock::{MappedMutexGuard, Mutex, MutexGuard};
+            #[doc = concat!("use synchrony::", stringify!($sync), "::mutex::{MappedMutexGuard, Mutex, MutexGuard};")]
             ///
             /// let data = Mutex::new(Some("value".to_string()));
             /// {

src/waker_slot.rs

@@ -1,11 +1,11 @@
 //! A slot holds up to one waker for task wakeup.
 //!
-//! `sync` version is just [`futures::task::AtomicWaker`]; unsync version is a
-//! hand-rolled singlethreaded version with similar API.
+//! `sync` version is just [`futures_util::task::AtomicWaker`]; unsync version
+//! is a hand-rolled singlethreaded version with similar API.
 
-/// Multithreaded `WakerSlot` based on [`futures::task::AtomicWaker`].
+/// Multithreaded `WakerSlot` based on [`futures_util::task::AtomicWaker`].
 pub mod sync {
-    pub use futures::task::AtomicWaker as WakerSlot;
+    pub use futures_util::task::AtomicWaker as WakerSlot;
 
     impl crate::AssertMt for WakerSlot {}
 }