Kā var pārvietot datu plūsmu no stāvokļa, kad tas tikai tiek izveidots, uz pastāvīga aktīva plūsmas stāvokli?

Android bieži izmanto Kotlin Flow bibliotēku datu plūsmu pārvaldībai. Datu plūsma stāvoklī "izveidojas" (cold flow) var tikt pārveidota par pastāvīgu aktīvu plūsmu (hot flow) ar operatoriem kā shareIn vai stateIn.

Piemēram, shareIn ļauj pārveidot cold flow par hot flow, kas sāk emitēt vērtības uzreiz pēc palaišanas un var tikt dalīts starp vairākiem abonentiem.

Piemērs:

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ādējādi, cold flow kļūst aktīvs un sāk emitēt datus neatkarīgi no abonentu klātbūtnes.