Как може да се прехвърли потокът от данни от състояние, в което е само създаден, към състояние на постоянен активен поток?

В Android често се използва библиотеката Kotlin Flow за управление на потоци от данни. Потокът от данни в състояние "създава се" (cold flow) може да бъде превърнат в постоянен активен поток (hot flow) с помощта на оператори като shareIn или stateIn.

Например, shareIn позволява да се превърне cold flow в hot flow, който започва да излъчва стойности веднага след стартирането си и може да бъде споделен между няколко абоната.

Пример:

val coldFlow = flow {
    emit(1)
    delay(1000)
    emit(2)
}

val hotFlow = coldFlow.shareIn(
    scope = CoroutineScope(Dispatchers.Default),
    started = SharingStarted.Eagerly,
    replay = 1
)

hotFlow.collect { value ->
    println(value)
}

По този начин cold flow става активен и започва да излъчва данни независимо от наличието на абонати.