آموزش استفاده از Shared Flow در اندروید

MutableSharedFlow یک نوع از Flow در کاتلین است که اجازه می‌دهد داده‌ها را تولید کنید و در چندین مکان مصرف کنید. این به توسعه‌دهندگان امکان می‌دهد که داده‌ها را به‌روز کنند و به اشتراک بگذارند، حتی در زمان اجرا.

ویژگی‌های کلیدی MutableSharedFlow

• تولید داده (Emit)

شما می‌توانید داده‌ها را با استفاده از `emit` ارسال کنید. به عبارت دیگر، شما می‌توانید داده‌های جدید را به MutableSharedFlow اضافه کنید.

• مصرف کننده‌های چندگانه (Multiple Consumers)

برخلاف بسیاری از نوع‌های دیگر Flow، شما می‌توانید چندین مصرف‌کننده داشته باشید. هر کدام از آن‌ها می‌توانند داده‌ها را به‌صورت همزمان مصرف کنند.

• استفاده در توابع Suspending و Non-Suspending

شما می‌توانید MutableSharedFlow را در توابع Suspending و Non-Suspending استفاده کنید. این به شما اجازه می‌دهد که از آن در کدهای همزمان و غیرهمزمان استفاده کنید.

• مدیریت خطاها

شما می‌توانید خطاها و استثناءها را در MutableSharedFlow مدیریت کنید و به مصرف‌کنندگان ارسال کنید.

• بازه‌های زمانی (Buffering)

شما می‌توانید بازه‌های زمانی برای MutableSharedFlow تعیین کنید تا داده‌ها را در آن مدت نگهداری کند و به مصرف‌کنندگان ارسال کند.

• بدون تاخیر در شروع (Replay)

MutableSharedFlow می‌تواند داده‌های موجود را به مصرف‌کنندگان جدید ارسال کند، حتی اگر آن‌ها بعد از شروع فرآیند ارسال و دریافت آن به برنامه بپیوندند.

کلیدی‌ترین نکته در استفاده از MutableSharedFlow این است که باید مواظبت کنید که همواره یک منبع معتبر داده در اختیار داشته باشید تا داده‌های صحیح و قابل اطمینان ارسال شوند.

با ارائه مثالی با زبان کاتلین سعی می‌کنم Shared Flow را بهتر برایتان توضیح دهم:

حساب کردن میانگین یک لیست از اعداد با استفاده از Shared Flow به شکل زیر می‌تواند یک مثال خوب باشد:

import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.asSharedFlow
import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

fun main() = runBlocking {
    // ایجاد یک Shared Flow برای ذخیره اعداد
    val numbersFlow = MutableSharedFlow<Int>()

    // تعریف یک اپراتور برای محاسبه میانگین
    fun calculateAverage(numbers: List<Int>): Double {
        return if (numbers.isNotEmpty()) {
            numbers.sum().toDouble() / numbers.size
        } else {
            0.0
        }
    }

    // افزودن اعداد به Shared Flow
    launch {
        for (i in 1..10) {
            numbersFlow.emit(i)
        }
        numbersFlow.emit(20)
    }

    // جمع‌آوری اعداد و محاسبه میانگین
    val numbersList = mutableListOf<Int>()
    val averageFlow = numbersFlow.asSharedFlow()
    launch {
        averageFlow.collect { number ->
            numbersList.add(number)
            val average = calculateAverage(numbersList)
            println("میانگین تا کنون: $average")
        }
    }
}