Add PatitionPublisher and PublisherPartition

spring-attic / reactive-streams-commons

A joint research effort for building highly optimized Reactive-Streams compliant operators.

Apache License 2.0

357 stars 51 forks source link

Open smaldini opened 8 years ago

smaldini commented 8 years ago

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 :

Partition resolution could be provided via key extractor and unlike GroupBy would use a fixed-delimited list of keys.