Structsยง
- Collector ๐Shim to implement a one-time
ParallelExtend
usingFromParallelIterator
. - Partition ๐An
UnzipOp
that routes items depending on a predicate function. - Partition
Map ๐AnUnzipOp
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
. - Unzip
Consumer ๐Consumer
that unzips into two otherConsumer
s - Unzip
Folder ๐Folder
that unzips into two otherFolder
s - Unzip
Reducer ๐Reducer
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. - execute_
into ๐Runs an unzip-like operation intoParallelExtend
collections. - partition ๐Partitions the items of a parallel iterator into a pair of arbitrary
ParallelExtend
containers. - partition_
map ๐Partitions and maps the items of a parallel iterator into a pair of arbitraryParallelExtend
containers. - unzip ๐Unzips the items of a parallel iterator into a pair of arbitrary
ParallelExtend
containers. - unzip_
indexed ๐Unzips anIndexedParallelIterator
into two arbitraryConsumer
s.