unzip.rs
SHA-256a3b15f9d0b617a98020b68d0a8f368202c5a24684c25bdf8653711e031559a77
Malecule∅
Evidence
1use super::plumbing::*;
2use super::*;
3
4/// This trait abstracts the different ways we can "unzip" one parallel
5/// iterator into two distinct consumers, which we c …
12 type Right: Send;
13
14 /// Consume one item and feed it to one or both of the underlying folders.
15 fn consume<FA, FB>(&self, item: T, left: …
19:36… support indexed consumers.
20 /// - e.g. true for `unzip` where the item count passed through directly.
21 /// - e.g. false for `partition` wher …
46:15… B: Send + ParallelExtend<OP::Right>
47{
48 // We have no idea what the consumers will look like for these
49 // collections' `par_extend`, but we ca …
49:57… hem in our own
50 // `drive_unindexed`. Start with the left side, type `A`:
51 let iter = UnzipA {
52 base: pi,
53 op: op,
54 b: b …