Jak lze přenést datový tok z stavu, kdy je teprve vytvářen, do stavu trvalého aktivního toku?

V Androidu se často používá knihovna Kotlin Flow k řízení datových toků. Datový tok ve stavu "vytváří se" (cold flow) lze pomocí operátorů jako shareIn nebo stateIn převést na stálý aktivní tok (hot flow).

Například shareIn umožňuje převést cold flow na hot flow, který začíná emitovat hodnoty ihned po spuštění a může být sdílen mezi několika odběrateli.

Příklad:

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)
}

Tímto způsobem se cold flow stává aktivním a začíná emitovat data bez ohledu na přítomnost odběratelů.