Возникла у меня тут задача:
- Есть поток данных. Довольно плотный: тысячи объектов в секунду.
- Его нужно писать в БД, но обрабатывать по одному долго.
- Соответственно, нужно собирать некоторое количество записей за определённый промежуток времени и писать одной транзакцией.
Среди стандартных методов ничего нужного не нашёл.
Сам, пока что, додумался только до такого:
suspend fun <T> Flow<T>.groupByTime(timeout : Duration): Flow<List<T>> = flow<List<T>> {
while (true) {
val list = mutableListOf<T>()
coroutineScope {
val job = launch(currentCoroutineContext()) {
collect { list.add(it) }
}
job.start()
delay(timeout)
job.cancelAndJoin()
}
if (list.size > 0) emit(list)
}
}
Если у кого есть решения лучше, предлагайте.
while(true)
- не лучшее решение. Но что-то не смог придумать, как по нормальному.