search

async-rs / parallel-stream

Data parallelism library for async-std.
https://docs.rs/parallel-stream
Apache License 2.0
93 stars 16 forks source link

Added skip and Skip struct to parallel stream. #12

Open justin1dennison opened 4 years ago

justin1dennison commented 4 years ago

I don't know if I am way off base with this implementation. I am having the following issue:


--> src/par_stream/skip.rs:42:23
   |
42 |         Skip { limit, receiver }
   |                       ^^^^^^^^ expected type parameter `T`, found associated type
   |
   = note: expected struct `async_std::sync::channel::Receiver<T>`
              found struct `async_std::sync::channel::Receiver<<S as par_stream::ParallelStream>::Item>`
   = note: you might be missing a type parameter or trait bound