mapAsyncPartitionedUnordered

Pass incoming elements to a partitioning function that returns a partition result for each element and then to a processing function that returns a Future CompletionStage result. The resulting Source or Flow will not have ordered elements.

Asynchronous operators

Signature

Source.mapAsyncPartitionedUnorderedSource.mapAsyncPartitionedUnordered Flow.mapAsyncPartitionedUnorderedFlow.mapAsyncPartitionedUnordered

Description

Like mapAsyncUnordered but an intermediate partitioning stage is used. Up to parallelism elements can be processed concurrently for a partition and pushed down the stream regardless of the order of the partitions that triggered them. In other words, the order of the output elements will be preserved only within a partition. For use cases where order matters, mapAsyncPartitioned can be used.

Reactive Streams semantics