GroupStrategy

A sealed interface representing different strategies for grouping items in a Flow. The GroupStrategy can be used in various contexts to control the way items are grouped together, optimizing the trade-off between latency and throughput.

Implementations of this interface can be used to specify the grouping behavior for items in a Flow, such as grouping by count or by time window.

Example usage:

val groupedFlow: Flow<List<T>> = sourceFlow.chunked(GroupStrategy.Count(10))
...
val splitFlow: Flow<Flow<T>> = sourceFlow.split(GroupStrategy.Count(10))

Subclasses:

• Count: Groups items based on a fixed count.

• TimeWindow: Groups items based on a time window with a maximum item count.

Inheritors