Click or drag to resize
Akka.NETSubFlowOperationsSelectAsyncUnorderedTIn, TOut, TMat, TClosed Method
Transform this stream by applying the given function asyncMapper to each of the elements as they pass through this processing step. The function returns a Task and the value of that task will be emitted downstream. As many tasks as requested elements by downstream may run in parallel and each processed element will be emitted downstream as soon as it is ready, i.e. it is possible that the elements are not emitted downstream in the same order as received from upstream. If the group by function asyncMapper throws an exception or if the Task is completed with failure and the supervision decision is Stop the stream will be completed with failure. If the group by function asyncMapper throws an exception or if theTask is completed with failure and the supervision decision is Resume or Restart the element is dropped and the stream continues.

Emits when any of the tasks returned by the provided function complete

Backpressures when the number of tasks reaches the configured parallelism and the downstream backpressures

Completes when upstream completes and all tasks has been completed and all elements has been emitted

Cancels when downstream cancels

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax
public static SubFlow<TOut, TMat, TClosed> SelectAsyncUnordered<TIn, TOut, TMat, TClosed>(
	this SubFlow<TIn, TMat, TClosed> flow,
	int parallelism,
	Func<TIn, Task<TOut>> asyncMapper
)

Parameters

flow
Type: Akka.Streams.DslSubFlowTIn, TMat, TClosed
TBD
parallelism
Type: SystemInt32
TBD
asyncMapper
Type: SystemFuncTIn, TaskTOut
TBD

Type Parameters

TIn
TBD
TOut
TBD
TMat
TBD
TClosed
TBD

Return Value

Type: SubFlowTOut, TMat, TClosed
TBD

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type SubFlowTIn, TMat, TClosed. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).
See Also