Hogyan lehet az adatfolyamot átvinni abból az állapotból, amikor csak létrejön, egy állandó aktív folyam állapotába?

Androidben az adatsorozások kezelésére gyakran használják a Kotlin Flow könyvtárat. Egy "készülő" (cold flow) adatfolyamot át lehet alakítani folyamatos aktív folyamra (hot flow) olyan operátorokkal, mint a shareIn vagy a stateIn.

Például a shareIn lehetővé teszi, hogy egy cold flow-t hot flow-vá alakítsunk, amely az indítás után azonnal kezd értékeket kibocsátani, és több feliratkozó között megosztható.

Példa:

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

Így a cold flow aktívvá válik, és elkezdi adatokat kibocsátani, függetlenül a feliratkozók jelenlététől.