Experimenting with Kotlin Actors

[idugalic]

Notice that pull request is already merged #70

This issue is going to track further progress (evolution) of this experimental API in FModel library.

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.

[idugalic]

#70 - merged