Is there map/filter on async_channel?

I checked the Sender/Receiver structs and could not find map/filter functions.

I think there is the issue we need tom somehow call tokio::spawn to run the task that does the mapping / filtering.

Since we have impl<T> Stream for Receiver<T>, you can find iterator-like combinators in futures::StreamExt.


This topic was automatically closed 90 days after the last reply. We invite you to open a new topic if you have further questions or comments.