Kotlin Actors (experimental) - concurrently handling messages

[idugalic]

Experimenting with Kotlin Actors - concurrently handling messages by confining the shared state effects.

fun <C, S, E> EventSourcingAggregate<C, S, E>.handleConcurrently(
    commands: Flow<C>,
    numberOfActors: Int = 100,
    actorsCapacity: Int = Channel.BUFFERED,
    actorsStart: CoroutineStart = CoroutineStart.LAZY,
    actorsContext: CoroutineContext = EmptyCoroutineContext,
    partitionKey: (C) -> Int
): Flow<E>

Extension function - Handles the Flow of messages by concurrently distributing the load across a finite number of actors/handlers. partitionKey function enables you to choose which messages need to be handled sequentially and which could be handled concurrently.

Notice, the API is experimental and depends on Kotlin Actor ObsoleteCoroutinesApi. The API is available only on jvm target.