Structs§
- Shim to implement a one-time
ParallelExtend
usingFromParallelIterator
. - An
UnzipOp
that routes items depending on a predicate function. - An
UnzipOp
that routes items depending on how they are mappedEither
. - UnEither 🔒An
UnzipOp
that routes items depending on theirEither
variant. - Unzip 🔒An
UnzipOp
that splits a tuple directly into the two consumers. - UnzipA 🔒A fake iterator to intercept the
Consumer
for typeA
. - UnzipB 🔒A fake iterator to intercept the
Consumer
for typeB
. Consumer
that unzips into two otherConsumer
sFolder
that unzips into two otherFolder
sReducer
that unzips into two otherReducer
s
Traits§
- UnzipOp 🔒This trait abstracts the different ways we can “unzip” one parallel iterator into two distinct consumers, which we can handle almost identically apart from how to process the individual items.
Functions§
- execute 🔒Runs an unzip-like operation into default
ParallelExtend
collections. - Runs an unzip-like operation into
ParallelExtend
collections. - Partitions the items of a parallel iterator into a pair of arbitrary
ParallelExtend
containers. - Partitions and maps the items of a parallel iterator into a pair of arbitrary
ParallelExtend
containers. - unzip 🔒Unzips the items of a parallel iterator into a pair of arbitrary
ParallelExtend
containers. - Unzips an
IndexedParallelIterator
into two arbitraryConsumer
s.