This repository was archived by the owner on Feb 25, 2022. It is now read-only.
This repository was archived by the owner on Feb 25, 2022. It is now read-only.
Add PatitionPublisher and PublisherPartition #12
Open
Description
Distribute the sequence onto N transformable Publisher
that can be eventually joined back.
Ex :
stream.partition(6).dispatchOn(ForkJoinPool.commonPool()).map(service::blockingTask).merge()
Supported PartitionPublisher operator :
- All PublisherBase
- merge()
- concat()
Partition resolution could be provided via key extractor and unlike GroupBy would use a fixed-delimited list of keys.