fix: prepare for edition 2024

Cargo.toml

@@ -40,6 +40,9 @@ slab = { version = "0.4.9", optional = true }
 smallvec = { version = "1.13", optional = true }
 futures-buffered = "0.2.9"
 
+[patch.crates-io]
+half = { version = "2.4.1", git = "https://github.com/VoidStarKat/half-rs.git", tag = "v2.4.1" }
+
 [dev-dependencies]
 async-io = "2.4"
 async-std = { version = "1.13.0", features = ["attributes"] }
@@ -50,7 +53,7 @@ criterion = { version = "0.5", features = [
 ] }
 futures = "0.3"
 futures-time = "3.0.0"
-itertools = "0.13"
+itertools = "0.14"
 lending-stream = "1.0.1"
-rand = "0.8.5"
+rand = "0.9.1"
 tokio = { version = "1.41", features = ["macros", "time", "rt-multi-thread"] }

src/concurrent_stream/from_stream.rs

@@ -28,7 +28,7 @@ where
     type Item = S::Item;
     type Future = Ready<Self::Item>;
 
-    async fn drive<C>(self, mut consumer: C) -> C::Output
+    async fn drive<C>(self, consumer: C) -> C::Output
     where
         C: Consumer<Self::Item, Self::Future>,
     {

src/future/join/tuple.rs

@@ -246,7 +246,7 @@ macro_rules! impl_join_tuple {
             fn drop(self: Pin<&mut Self>) {
                 let this = self.project();
 
-                let ($(ref mut $F,)+) = this.outputs;
+                let &mut ($(ref mut $F,)+) = this.outputs;
 
                 let states = this.state;
                 let mut futures = this.futures;

src/future/mod.rs

@@ -18,7 +18,7 @@
 //!     let b = future::ready(2);
 //!     let c = future::ready(3);
 //!     assert_eq!([a, b, c].join().await, [1, 2, 3]);
-//!    
+//!
 //!     // Await multiple differently-typed futures.
 //!     let a = future::ready(1u8);
 //!     let b = future::ready("hello");
@@ -66,7 +66,7 @@
 //!
 //! - `future::TryMerge`: wait for all futures in the set to complete _successfully_, or return on the first error.
 //! - `future::RaceOk`: wait for the first _successful_ future in the set to
-//!    complete, or return an `Err` if *no* futures complete successfully.
+//!   complete, or return an `Err` if *no* futures complete successfully.
 //!
 #[doc(inline)]
 #[cfg(feature = "alloc")]

src/future/try_join/tuple.rs

@@ -280,7 +280,7 @@ macro_rules! impl_try_join_tuple {
             fn drop(self: Pin<&mut Self>) {
                 let this = self.project();
 
-                let ($(ref mut $F,)+) = this.outputs;
+                let &mut ($(ref mut $F,)+) = this.outputs;
 
                 let states = this.state;
                 let mut futures = this.futures;

src/utils/poll_state/maybe_done.rs

@@ -37,10 +37,9 @@ where
             MaybeDone::Done(Ok(_)) => {}
             MaybeDone::Done(Err(_)) | MaybeDone::Future(_) | MaybeDone::Gone => return None,
         }
-        if let MaybeDone::Done(Ok(output)) = mem::replace(this, MaybeDone::Gone) {
-            Some(output)
-        } else {
-            unreachable!()
+        match mem::replace(this, MaybeDone::Gone) {
+            MaybeDone::Done(Ok(output)) => Some(output),
+            _ => unreachable!(),
         }
     }
 
@@ -53,10 +52,9 @@ where
             MaybeDone::Done(Err(_)) => {}
             MaybeDone::Done(Ok(_)) | MaybeDone::Future(_) | MaybeDone::Gone => return None,
         }
-        if let MaybeDone::Done(Err(output)) = mem::replace(this, MaybeDone::Gone) {
-            Some(output)
-        } else {
-            unreachable!()
+        match mem::replace(this, MaybeDone::Gone) {
+            MaybeDone::Done(Err(output)) => Some(output),
+            _ => unreachable!(),
         }
     }
 }