mapAsyncUnordered

As explained in Akka in Action, Second Edition

mapAsyncUnordered is an Akka Streams operator that applies asynchronous processing with bounded parallelism while emitting results as they complete rather than preserving input order.

mapAsyncUnordered applies asynchronous work to stream elements with bounded parallelism and emits completed results without waiting for earlier, slower elements. Use it when input order is unnecessary and processing times vary. section 16.1.2 section 16.5

A slow database query or remote request does not hold back faster work: completed elements leave the stage, freeing capacity for new elements. The benefit grows as per-element response times differ more widely. section 16.1.2

Variable-latency service calls

For asynchronous database, HTTP, gRPC, or FTP calls, use unordered processing when later responses may safely arrive first. Keep ordered processing when downstream logic requires the original sequence. section 16.1.2 section 16.5

Figure 16.1 mapAsyncUnordered allowing new elements to be processed

The diagram shows faster elements leaving the asynchronous stage first, making room for additional work while slower elements remain in flight. section 16.1.2

Operational guidance:

• Choose mapAsyncUnordered for high-variance work only when result order is irrelevant. section 16.1.2 section 16.5
• Consider the external service’s request capacity when raising parallelism. section 16.1.2
• Use async stream stages to pass a prior stage’s element into an external call and process its response in the following stage. section 16.5

How Akka in Action, Second Edition covers it

How deep it goes

Explains completion-first behavior and performance rationale, without detailing the operator’s implementation internals.

Examples

Uses database queries with different response times and a diagram of faster elements freeing asynchronous-stage capacity.

What you can do after

Evaluate/understand when completion-order emission improves throughput for variable-latency asynchronous work.

How it connects

Connects asynchronous stream stages with databases, HTTP, gRPC, FTP, mapAsync, throttling, and exception handling.

liveBookmanning.com

Read Akka in Action, Second Edition on liveBook Get the book at manning.com

Related concepts

• serviceuses · A service is a capability or activity provided by an entity to meet the needs of users or other components.
• varianceaddresses · Variance is the expected squared deviation of a random variable from its mean, measuring the spread of its distribution.

This explainer was generated by Manning's knowledge graph from the text of Akka in Action, Second Edition. The section links point to the parts of the book it draws on.