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:slab"]
+waker_slot = ["dep:futures-util"]
 event = ["dep:event-listener", "dep:local-event"]
 bilock = ["waker_slot"]
 

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

@@ -90,7 +90,6 @@ macro_rules! impl_mutex {
             task::{Context, Poll},
         };
 
-        use futures::future::FusedFuture;
         use slab::Slab;
 
         use super::*;
@@ -269,12 +268,6 @@ macro_rules! impl_mutex {
             }
         }
 
-        impl<T: ?Sized> FusedFuture for OwnedMutexLockFuture<T> {
-            fn is_terminated(&self) -> bool {
-                self.mutex.is_none()
-            }
-        }
-
         impl<T: ?Sized> Future for OwnedMutexLockFuture<T> {
             type Output = OwnedMutexGuard<T>;
 
@@ -389,12 +382,6 @@ macro_rules! impl_mutex {
             }
         }
 
-        impl<T: ?Sized> FusedFuture for MutexLockFuture<'_, T> {
-            fn is_terminated(&self) -> bool {
-                self.mutex.is_none()
-            }
-        }
-
         impl<'a, T: ?Sized> Future for MutexLockFuture<'a, T> {
             type Output = MutexGuard<'a, T>;
 
@@ -457,7 +444,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 +516,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 {}
 }