From 23d9497e7ff54f48a4c07247d7f1f68270b510d2 Mon Sep 17 00:00:00 2001
From: Héctor Ramón Jiménez <hector@hecrj.dev>
Date: Mon, 8 Jul 2024 01:13:22 +0200
Subject: Allow future in `stream::channel` to return

---
 futures/src/stream.rs | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

(limited to 'futures')

diff --git a/futures/src/stream.rs b/futures/src/stream.rs
index 2ec505f1..06f9230d 100644
--- a/futures/src/stream.rs
+++ b/futures/src/stream.rs
@@ -1,6 +1,5 @@
 //! Create asynchronous streams of data.
 use futures::channel::mpsc;
-use futures::never::Never;
 use futures::stream::{self, Stream, StreamExt};
 
 use std::future::Future;
@@ -16,11 +15,11 @@ pub fn channel<T, F>(
     f: impl FnOnce(mpsc::Sender<T>) -> F,
 ) -> impl Stream<Item = T>
 where
-    F: Future<Output = Never>,
+    F: Future<Output = ()>,
 {
     let (sender, receiver) = mpsc::channel(size);
 
-    let runner = stream::once(f(sender)).map(|_| unreachable!());
+    let runner = stream::once(f(sender)).filter_map(|_| async { None });
 
     stream::select(receiver, runner)
 }
-- 
cgit