Structsยง
- Collector ๐Shim to implement a one-time
ParallelExtend
usingFromParallelIterator
. - Partition ๐An
UnzipOp
that routes items depending on a predicate function. - PartitionMap ๐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
. - UnzipConsumer ๐
Consumer
that unzips into two otherConsumer
s - UnzipFolder ๐
Folder
that unzips into two otherFolder
s - UnzipReducer ๐
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 into
ParallelExtend
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 arbitrary
ParallelExtend
containers. - unzip ๐Unzips the items of a parallel iterator into a pair of arbitrary
ParallelExtend
containers. - unzip_indexed ๐Unzips an
IndexedParallelIterator
into two arbitraryConsumer
s.