parallel-stream
parallel-stream copied to clipboard
async-rs
Data parallelism library for async-std.
It should be possible to limit the max concurrency. This likely needs to be built into the `ParallelStream` trait itself, with each impl being responsible for carrying it. The default...
With standard iterators, it's possible to call `map` with a function that returns a `Result`, then collect into a `Result`. I'd like to do something similar with a `ParallelStream`, but...
I am wondering why `ParallelStream` requires `T` to be `Sync` where `async_std::task::spawn` requires the spawned future only to be `Send + 'static`. I ran into this issue when trying to...
## On Restrospection I've been looking for parallelism combined with async/await and thanks for your decent work. I'd like to share to retrospection on pulling this crate in my existing...
I have started working on the from_fn free function. However, I may need a little guidance in the implementation. I tried to smoke test the function, but was not able...
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...
This PR adds the `Count` struct and the `ParallelStream::count` method.
