collect

collect ile Flow tüketmeyi öğrenirsin.

collect: Terminal operatör

collect bir terminal operatördür: akışı başlatır ve değerleri tüketir. Ara operatörlerin (map, filter) aksine, collect çağrılmazsa akış hiç çalışmaz. Bu yüzden Flow'a "soğuk" denir.

fun numbers(): Flow<Int> = flowOf(1, 2, 3)

fun main() = runBlocking {
    numbers().collect { println(it)
    }
}

collect bir suspend fonksiyondur; yalnızca coroutine içinde çağrılır. Lambda, her emit değeri için sırayla çalışır. Akış bittiğinde collect döner ve main devam eder.

collect bir coroutine içinde

collect bir suspend fonksiyon olduğu için yalnızca bir coroutine içinden çağrılabilir. main'de runBlocking { ... } kullanmak, akışı senkron çağrıyla köprüler. Böylece program, akış bitene kadar bekler.

fun main() = runBlocking {
    var sum = 0
    numbers().collect { sum += it }
    println(sum)
}

Burada collect her değerde sum += it yapar; akış bitince println(sum) çalışır. Lambda içinden dış değişkeni değiştirmek (burada sum) küçük akışlarda güvenlidir. Daha karmaşık durumlarda fold gibi operatörler tercih edilir.

Uygulama collect ile değerleri topla

fun numbers(): Flow<Int> = flowOf(1, 2, 3) tanımla. main'i runBlocking ile işaretle. İçinde var sum = 0 başlat; numbers().collect { sum += it } ile değerleri topla; println(sum) ile sonucu yazdır.

Örnek çözümü göster

fun numbers(): Flow<Int> = flowOf(1, 2, 3)

fun main() = runBlocking {
    var sum = 0
    numbers().collect { sum += it }
    println(sum)
}

Kendini test et

flow.collect { ... } ne yapar?
- Akışı tüketir; her değer için lambda çalıştırır
- Akışı listeye çevirir
- Akışı başlatır ama değer almaz
- Akışı iptal eder
Cevabı göster

Akışı tüketir; her değer için lambda çalıştırır — collect terminal'dir; her emit değeri için lambda'yı çalıştırır.
collect kavramlarını eşle

collect { }

Tüketici
terminal

Son işlem
suspend

Beklemeli
println(it)

Değeri yazdırır

Akışı tüket

fun main() = runBlocking {
    numbers().____ { println(it) }
}

Cevabı göster

fun main() = runBlocking {
    numbers().collect { println(it) }
}

Sıradaki ders: map ve filter

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler