Module unzip

Source

Structsยง

Collector ๐Ÿ”’
Shim to implement a one-time ParallelExtend using FromParallelIterator.
Partition ๐Ÿ”’
An UnzipOp that routes items depending on a predicate function.
PartitionMap ๐Ÿ”’
An UnzipOp that routes items depending on how they are mapped Either.
UnEither ๐Ÿ”’
An UnzipOp that routes items depending on their Either variant.
Unzip ๐Ÿ”’
An UnzipOp that splits a tuple directly into the two consumers.
UnzipA ๐Ÿ”’
A fake iterator to intercept the Consumer for type A.
UnzipB ๐Ÿ”’
A fake iterator to intercept the Consumer for type B.
UnzipConsumer ๐Ÿ”’
Consumer that unzips into two other Consumers
UnzipFolder ๐Ÿ”’
Folder that unzips into two other Folders
UnzipReducer ๐Ÿ”’
Reducer that unzips into two other Reducers

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 arbitrary Consumers.