التمييز بين التدفق البارد والحالة الحالية المشتركة

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

fun main() = runBlocking {
    val values = flowOf(1, 2, 3)
        .map { it * 10 }
        .filter { it >= 20 }
    values.collect { println(it) }
}

20
30

المخرجان المتوقعان هما 20 ثم 30. لا توجد عملية تخزين وسيط أو تزامن تغيّر ترتيب هذا المسار البسيط. لم تُنفّذ بيئة كوروتينات أو عملية ترجمة.

import kotlinx.coroutines.flow.*

data class ScreenState(val selected: Int)
fun main() {
    val mutable = MutableStateFlow(ScreenState(0))
    val state: StateFlow<ScreenState> = mutable.asStateFlow()
    mutable.update { current -> current.copy(selected = current.selected + 1) }
    println(state.value.selected)
}

1

المخرج المتوقع 1. تحوّل update الحالة الحالية ذريّا، وقد تُقيَّم lambda الصرفة أكثر من مرة عند التنافس، لذلك أبعد الآثار الجانبية عنها. يحتاج المصدر kotlinx.coroutines، ولم يُنفّذ.