From 4e290f91358eb734cdd83168418ccc24a10dc31a Mon Sep 17 00:00:00 2001
From: Alexander Jiang <alexander.jiang@discordapp.com>
Date: Wed, 8 Jan 2025 17:40:28 +0000
Subject: [PATCH] map the infinite-loop future to return a Result instead

---
 src/topology/running.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/topology/running.rs b/src/topology/running.rs
index 0cd0cd646bdb6..9a5c302185912 100644
--- a/src/topology/running.rs
+++ b/src/topology/running.rs
@@ -196,7 +196,7 @@ impl RunningTopology {
         // Aggregate future that ends once anything detects that all tasks have shutdown.
         let shutdown_complete_future = future::select_all(vec![
             Box::pin(timeout) as future::BoxFuture<'static, Result<(), ()>>,
-            Box::pin(reporter) as future::BoxFuture<'static, ()>,
+            Box::pin(reporter.map(|()| Result::<(), ()>::Ok(()))) as future::BoxFuture<'static, Result<(), ()>>,
             Box::pin(success) as future::BoxFuture<'static, Result<(), ()>>,
         ]);