parallel-stream icon indicating copy to clipboard operation
parallel-stream copied to clipboard

Filter Map: Add to project

Open CollinValley opened this issue 5 years ago • 0 comments

This follows, pretty closely, the pattern used to create Map. The new function spawns a ton of tasks to process each value from the input stream, which are then collected into a channel. Values are pulled from the channel and output via poll_next. The only substantive difference between this and Map is that the provided closure must return a future that yields an Option<T>, rather than a T.

CollinValley avatar Mar 22 '20 23:03 CollinValley