Skip to content

Conversation

CollinValley
Copy link

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, rather than a T.

@CollinValley CollinValley mentioned this pull request Mar 22, 2020
79 tasks
Simple fixup with Cargo Fmt, so the tests pass.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant