concurrent<State extends Object?> function

FunctionHandler<State> concurrent<State extends Object?>()

Process tasks concurrently without any restrictions.

Use with caution as concurrent state updates may lead to race conditions.

Implementation

FunctionHandler<State> concurrent<State extends Object?>() =>
    StreamFunctionHandler<State>(
        handleTransformer: HandleTaskTransformers.concurrent());