Kotlin Flow против Android LiveData

У меня есть несколько вопросов о Kotlin Flow

1. Я могу наблюдать LiveData из нескольких фрагментов. Могу ли я сделать это с Flow? Если да, то как?
2. Мы можем иметь несколько LiveData из одной LiveData, используя map& switchMap. Есть ли способ иметь несколько потоков из одного источника потока?
3. Используя MutableLiveDataя могу обновить данные из любой точки мира, используя ссылку на переменную. Есть ли способ сделать то же самое с Flow?

У меня есть такой пример использования: я буду наблюдать за SharedPreferencesиспользованием, callbackFlow{...}которое даст мне единственный источник потока. Из этого потока я хочу создать несколько потоков для каждой пары ключ-значение.

Это может звучать глупо. Я новичок в мире Rx и Flow.

Я могу наблюдать LiveData из нескольких фрагментов. Могу ли я сделать это с Flow? Если да, то как?

Да. Вы можете сделать это с emitи collect. Мысли emitпохожи на живые данные postValueи collectпохожи на observe. Давайте приведем пример.

вместилище

// I just faked the weather forecast
val weatherForecast = listOf("10", "12", "9")

// This function returns flow of forecast data
// Whenever the data is fetched, it is emitted so that
// collector can collect (if there is any)
fun getWeatherForecastEveryTwoSeconds(): Flow<String> = flow { 
    for (i in weatherForecast) {
        delay(2000)
        emit(i)
    }
}

ViewModel

fun getWeatherForecast(): Flow<String> {
    return forecastRepository.getWeatherForecastEveryTwoSeconds()
}

Фрагмент

override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
    // Collect is suspend function. So you have to call it from a 
    // coroutine scope. You can create a new coroutine or just use 
    // lifecycleScope
    // https://developer.android.com/topic/libraries/architecture/coroutines
    lifecycleScope.launch {
            viewModel.getWeatherForecastEveryTwoSeconds().collect {
                    // Use the weather forecast data
                    // This will be called 3 times since we have 3 
                    // weather forecast data
            }
    }
}

Мы можем иметь несколько LiveData из одной LiveData, используя map & switchMap. Есть ли способ иметь несколько потоков из одного источника потока?

Поток очень удобен. Вы можете просто создать поток внутри потока. Допустим, вы хотите добавить знак градуса к каждому из данных прогноза погоды.

ViewModel

fun getWeatherForecast(): Flow<String> {
    return flow {
        forecastRepository
            .getWeatherForecastEveryTwoSeconds(spendingDetailsRequest)
                .map {
                    it + " °C"
                }
                .collect {
                    // This will send "10 °C", "12 °C" and "9 °C" respectively
                    emit(it) 
                }
    }
}

Затем соберите данные во фрагменте так же, как # 1. Здесь происходит то, что модель представления собирает данные из хранилища, а фрагмент собирает данные из модели представления.

Используя MutableLiveData, я могу обновлять данные из любой точки мира, используя ссылку на переменную. Есть ли способ сделать то же самое с Flow?

Вы не можете излучать значение вне потока. Блок кода внутри потока выполняется только при наличии какого-либо коллектора. Но вы можете преобразовать поток в живые данные, используя расширение asLiveData из LiveData.

ViewModel

fun getWeatherForecast(): LiveData<String> {
    return forecastRepository
    .getWeatherForecastEveryTwoSeconds()
    .asLiveData() // Convert flow to live data
}

В вашем случае вы можете сделать это

private fun getSharedPrefFlow() = callbackFlow {
    val sharedPref = context?.getSharedPreferences("SHARED_PREF_NAME", MODE_PRIVATE)
    sharedPref?.all?.forEach {
        offer(it)
    }
}

getSharedPrefFlow().collect {
    val key = it.key
    val value = it.value
}

редактировать

Спасибо @mark за его комментарий. Создание нового потока в модели представления для getWeatherForecastфункции фактически не требуется . Это может быть переписано как

fun getWeatherForecast(): Flow<String> {
        return forecastRepository
                .getWeatherForecastEveryTwoSeconds(spendingDetailsRequest)
                    .map {
                        it + " °C"
                    }
    }

Есть новая Flow.asLiveData()функция расширения в новомandroidx.lifecycle пакетах ktx . Вы можете узнать больше в моей статье: https://www.netguru.com/codestories/android-coroutines-%EF%B8%8Fin-2020

В трехуровневой архитектуре: представление предметной области, поток должен происходить на уровне данных (базы данных, сеть, кэш-память ...) и затем как отметил Сэмюэль Урбанович, вы можете сопоставить поток с LiveData.

В общем, Flow - это почти то, что Observable (или Flowable) для RxJava. Не путайте это с LiveData.

больше здесь: https://medium.com/@elizarov/cold-flows-hot-channels-d74769805f9