implement FusedStream for Receiver

Question

implement FusedStream for Receiver

fogti opened this issue 5 years ago · 4 comments

as Receiver can detect if the channel is closed, it probably can implement FusedStream...
see also concurrent_queue::ConcurrentQueue::is_closed

Answer 1 · 2020-06-12T11:31:53.000Z

impl<T> FusedStream for Receiver<T> {
    fn is_terminated(&self) {
        self.channel.queue.is_closed() && self.channel.queue.is_empty()
    }
}

Answer 2 · 2020-06-12T12:19:24.000Z

I'm curious: in what cases is FusedStream useful or used in practice?

This sounds good - just a small correction: the Receiver is terminated when the queue is closed and is empty.

Answer 3 · 2020-06-12T13:38:56.000Z

It is i.a. used for using the futures::select! macro without needing to .fuse() the Stream.

Answer 4 · 2021-01-06T09:47:50.000Z

As FusedStream is defined in futures-core, this wouldn't even require another dependency. It would be a really small change which increases usability.