Embabel Agent Documentation/com.embabel.agent.spi.support/ExecutorAsyncer

ExecutorAsyncer

class ExecutorAsyncer(executor: Executor) : Asyncer

Asyncer implementation that uses an Executor for async operations, propagating to worker threads the AgentProcess (a domain concern, via AgentProcessAccessor) and the current Micrometer Observation (via the official ContextSnapshotFactory, so spans nest across threads; a no-op when no observation is current, e.g. a NOOP registry).

Constructors

ExecutorAsyncer

constructor(executor: Executor)

Functions

async

open override fun <T> async(block: () -> T): CompletableFuture<T>

parallelMap

open override fun <T, R> parallelMap(items: Collection<T>, maxConcurrency: Int, transform: (t: T) -> R): List<R>