I tried to (manually) implement a Stream where the poll_next impl. would in turn poll the Future created from select of async_broadcast::Recv and async_channel::Recv but it'd lock up and not getting new messages. I changed the impl. to use <Receiver as StreamNext>::next and it worked just fine.
I will try to create a simple testcase for this but just wanted to create an issue first so I don't forget.
I tried to (manually) implement a
Stream
where thepoll_next
impl. would in turn poll the Future created fromselect
ofasync_broadcast::Recv
andasync_channel::Recv
but it'd lock up and not getting new messages. I changed the impl. to use<Receiver as StreamNext>::next
and it worked just fine.I will try to create a simple testcase for this but just wanted to create an issue first so I don't forget.