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 dowstream 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

public static Source<TOut, TMat> SelectAsyncUnordered<TIn, TOut, TMat>(
	this Source<TIn, TMat> flow,
	int parallelism,
	Func<TIn, Task<TOut>> asyncMapper
)

[<ExtensionAttribute>]
static member SelectAsyncUnordered : 
        flow : Source<'TIn, 'TMat> * 
        parallelism : int * 
        asyncMapper : Func<'TIn, Task<'TOut>> -> Source<'TOut, 'TMat>