chore(deps): bump futures to 0.3.32 (#25522)

* chore(deps): bump futures to 0.3.32, fix try_recv breaking change

Co-Authored-By: Claude <claude-sonnet-4-6>

* fmt

Author: thomasqueirozb

Cargo.lock

@@ -157,7 +157,7 @@ dashmap = { version = "6.1.0", default-features = false }
 derivative = { version = "2.2.0", default-features = false }
 exitcode = { version = "1.1.2", default-features = false }
 flate2 = { version = "1.1.2", default-features = false, features = ["zlib-rs"] }
-futures = { version = "0.3.31", default-features = false, features = ["std"] }
+futures = { version = "0.3.32", default-features = false, features = ["std"] }
 futures-util = { version = "0.3.29", default-features = false }
 glob = { version = "0.3.3", default-features = false }
 hickory-proto = { version = "0.26.1", default-features = false, features = ["dnssec-ring"] }

Cargo.toml

@@ -1,11 +1,7 @@
 use std::sync::Arc;
 
 use bytes::Bytes;
-use futures::{
-    StreamExt,
-    channel::mpsc::{Receiver, TryRecvError},
-    stream::Stream,
-};
+use futures::{StreamExt, channel::mpsc::Receiver, stream::Stream};
 use hyper::StatusCode;
 use indoc::indoc;
 use similar_asserts::assert_eq;
@@ -105,7 +101,7 @@ async fn smoke() {
 async fn handles_failure() {
     let (_expected, mut rx) = start_test(StatusCode::FORBIDDEN, BatchStatus::Rejected).await;
 
-    assert!(matches!(rx.try_next(), Err(TryRecvError { .. })));
+    assert!(rx.try_recv().is_err());
 }
 
 #[tokio::test]

src/sinks/datadog/events/tests.rs

@@ -4,10 +4,7 @@ use std::sync::Arc;
 
 use bytes::Bytes;
 use chrono::Utc;
-use futures::{
-    StreamExt,
-    channel::mpsc::{Receiver, TryRecvError},
-};
+use futures::{StreamExt, channel::mpsc::Receiver};
 use http::request::Parts;
 use indoc::indoc;
 use vector_lib::{
@@ -195,9 +192,9 @@ async fn telemetry() {
 async fn handles_failure_v1() {
     let (_expected, mut rx) =
         start_test_error(ApiStatus::BadRequestv1, BatchStatus::Rejected).await;
-    let res = rx.try_next();
+    let res = rx.try_recv();
 
-    assert!(matches!(res, Err(TryRecvError { .. })));
+    assert!(res.is_err());
 }
 
 #[tokio::test]
@@ -209,9 +206,9 @@ async fn handles_failure_v1() {
 async fn handles_failure_v2() {
     let (_expected, mut rx) =
         start_test_error(ApiStatus::BadRequestv2, BatchStatus::Rejected).await;
-    let res = rx.try_next();
+    let res = rx.try_recv();
 
-    assert!(matches!(res, Err(TryRecvError { .. })));
+    assert!(res.is_err());
 }
 
 #[tokio::test]

src/sinks/datadog/logs/tests.rs

@@ -524,7 +524,7 @@ mod tests {
     async fn smoke_fails() {
         let (_hosts, _partitions, mut rx) =
             smoke_start(StatusCode::FORBIDDEN, BatchStatus::Rejected).await;
-        assert!(matches!(rx.try_next(), Err(mpsc::TryRecvError { .. })));
+        assert!(rx.try_recv().is_err());
     }
 
     #[tokio::test]