diff options
| -rw-r--r-- | futures/src/stream.rs | 5 |
1 files changed, 2 insertions, 3 deletions
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) } |