mapAsync
Maps values through transform with up to concurrency invocations in flight, preserving upstream order.
A result is emitted only after the results of all earlier values have been emitted, so one slow transform delays later results. The upstream is collected only while permits are available, which bounds memory at concurrency pending results. A failure in transform or the upstream cancels all in-flight work and fails the flow.
Throws
if concurrency is less than 1.