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.
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.