Is there map/filter on async_channel?

1

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.

2

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

2 Likes