storm-kotlin/st.orm.repository.impl

Package-level declarations

Types

class EntityRepositoryImpl<E : Data, Entity<ID>, ID : Any>(core: EntityRepository<E, ID>) : EntityRepository<E, ID>

class ProjectionRepositoryImpl<P : Data, Projection<ID>, ID : Any>(core: ProjectionRepository<P, ID>) : ProjectionRepository<P, ID>

Functions

chunked

fun <T> Flow<T>.chunked(size: Int): Flow<List<T>>

Splits the given flow into a flow of non-overlapping lists each not exceeding the given size but never empty. The last emitted list may have fewer elements than the given size.

flatMapConcat

fun <T, R> Flow<T>.flatMapConcat(transform: suspend (value: T) -> Flow<R>): Flow<R>

Transforms elements emitted by the original flow by applying transform, that returns another flow, and then concatenating and flattening these flows.

flattenConcat

fun <T> Flow<Flow<T>>.flattenConcat(): Flow<T>

Flattens the given flow of flows into a single flow in a sequential manner, without interleaving nested flows.