Package com.embabel.agent.api.dsl
Class MapperKt
-
- All Implemented Interfaces:
public final class MapperKt
-
-
Method Summary
Modifier and Type Method Description final static <T extends Any, R extends Any> List<R>parallelMap(Collection<T> $self, OperationContext context, Integer concurrencyLevel, CoroutineDispatcher dispatcher, SuspendFunction1<T, R> transform)Map parallel. final static <T extends Any, R extends Any> List<R>mapAsync(Collection<T> $self, OperationContext context, Integer concurrencyLevel, CoroutineDispatcher dispatcher, SuspendFunction1<T, R> transform)Map async, using the agent process -
-
Method Detail
-
parallelMap
final static <T extends Any, R extends Any> List<R> parallelMap(Collection<T> $self, OperationContext context, Integer concurrencyLevel, CoroutineDispatcher dispatcher, SuspendFunction1<T, R> transform)
Map parallel. Block on all results
- Parameters:
context- the operation contextconcurrencyLevel- the maximum number of concurrent operationsdispatcher- the coroutine dispatcher to use for parallel executiontransform- the transformation function to apply to each element
-
mapAsync
final static <T extends Any, R extends Any> List<R> mapAsync(Collection<T> $self, OperationContext context, Integer concurrencyLevel, CoroutineDispatcher dispatcher, SuspendFunction1<T, R> transform)
Map async, using the agent process
-
-
-
-