SharedFlow

SharedFlow ile paylaşılan akış öğrenirsin.

SharedFlow nedir?

SharedFlow, birden fazla toplayıcıya aynı anda yayın yapan sıcak bir akıştır. StateFlow'tan farklı olarak bir başlangıç değeri taşımaz; yalnızca yayın yapılan değerleri iletir.

Bir MutableSharedFlow<T>() ile oluşturulur; .emit(value) ile değer gönderilir. Yeni toplayıcılar yalnızca sonraki yayınları alır. Olay tabanlı bildirimler için uygundur: bir butona tıklama, bir mesaj geldiğinde uyarı verme gibi. replay parametresi ile son N değeri yeni toplayıcılara verecek şekilde yapılandırılabilir.

SharedFlow kullanımı

Bir MutableSharedFlow açıp bir launch içinde .collect ile dinlersin. Başka bir coroutine .emit ile değer gönderince toplayıcı onu alır.

Örnek: val flow = MutableSharedFlow<Int>(). Bir launch içinde flow.collect { v -> println(v) } açarsın, ana akışta flow.emit(1) dediğinde toplayıcı 1 alır. Aynı anda ikinci bir collect açarsan her iki toplayıcı da değeri alır.

Uygulama SharedFlow ile emit ve collect

val flow = MutableSharedFlow<Int>() tanımla. Bir launch içinde flow.collect { value -> println("Aldı: $value") } aç. delay(100) sonrası flow.emit(1) çağır, delay(100) bekle ve job.cancel() ile toplayıcıyı durdur.

Örnek çözümü göster

fun main() = runBlocking {
    val flow = MutableSharedFlow<Int>()
    val job = launch {
        flow.collect { value -> println("Aldı: $value") }
    }
    delay(100)
    flow.emit(1)
    delay(100)
    job.cancel()
}

Kendini test et

SharedFlow parçalarını eşle

MutableSharedFlow

Yayın taşıyıcı
.emit

Değer gönderir
.collect

Toplama
replay

Son N değer
SharedFlow'ın başlangıç değeri var mıdır?
- Evet, her zaman
- Yalnızca suspend ile
- Sadece Int için
- Hayır, yoktur
Cevabı göster

Hayır, yoktur — SharedFlow başlangıç değeri taşımaz.

SharedFlow tür parametresini tamamla

val flow = MutableSharedFlow<____>()

Cevabı göster

val flow = MutableSharedFlow<Int>()

Sıradaki ders: Channel

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler