Skip to content
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
@smaldini

Description

@smaldini

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.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions