Skip to content
This repository has been archived by the owner on Feb 25, 2022. It is now read-only.

Add PatitionPublisher and PublisherPartition #12

Open
smaldini opened this issue Feb 20, 2016 · 0 comments
Open

Add PatitionPublisher and PublisherPartition #12

smaldini opened this issue Feb 20, 2016 · 0 comments

Comments

@smaldini
Copy link
Contributor

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.

@smaldini smaldini changed the title Add ParallelPublisher and PublisherParallel Add PatitionPublisher and PublisherPartition Feb 20, 2016
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Development

No branches or pull requests

1 participant