feat: Switch from futures to futures_util

Cargo.toml

@@ -21,10 +21,10 @@ smallvec = "1.13.1"
 memoffset = "0.9.0"
 pin-project-lite = "0.2.13"
 tokio = { version = "1.36.0", features = ["net", "macros", "io-util"] }
-futures = "0.3.30"
 ktls-sys = "1.0.1"
 ktls-recvmsg = { version = "0.1.3" }
 num_enum = "0.7.2"
+futures-util = "0.3.30"
 
 [dev-dependencies]
 lazy_static = "1.4.0"

src/cork_stream.rs

@@ -82,7 +82,7 @@ where
                     {
                         let mut rest = ReadBuf::new(&mut header_buf[*offset..]);
                         tracing::trace!("reading header: doing i/o");
-                        futures::ready!(io.as_mut().poll_read(cx, &mut rest)?);
+                        futures_util::ready!(io.as_mut().poll_read(cx, &mut rest)?);
                         tracing::trace!("reading header: io was ready");
                         *offset += rest.filled().len();
                         if rest.filled().is_empty() {
@@ -135,7 +135,7 @@ where
 
                     let just_read = {
                         let mut rest = buf.take(rest);
-                        futures::ready!(io.as_mut().poll_read(cx, &mut rest)?);
+                        futures_util::ready!(io.as_mut().poll_read(cx, &mut rest)?);
 
                         tracing::trace!("read {} bytes off of payload", rest.filled().len());
                         *offset += rest.filled().len();

src/lib.rs

@@ -1,5 +1,5 @@
 use ffi::{setup_tls_info, setup_ulp, KtlsCompatibilityError};
-use futures::future::try_join_all;
+use futures_util::future::try_join_all;
 use ktls_sys::bindings as sys;
 use rustls::{Connection, SupportedCipherSuite, SupportedProtocolVersion};