Android: пользовательский наблюдатель Kotlin LiveData/MutableLiveData

Как решить проблему отписки наблюдателя после однократного получения обновления

LiveData — это наблюдаемый класс держателя данных. В отличие от обычного наблюдаемого, LiveData учитывает жизненный цикл, то есть учитывает жизненный цикл других компонентов приложения, таких как действия, фрагменты или службы. Эта осведомленность гарантирует, что LiveData обновляет только наблюдатели компонентов приложения, которые находятся в активном состоянии жизненного цикла.

Как это работает: LiveData считает, что наблюдатель, представленный классом Observer, находится в активном состоянии, если его жизненный цикл находится в состоянии STARTED или RESUMED. LiveData уведомляет только активных наблюдателей об обновлениях. Неактивные наблюдатели, зарегистрированные для наблюдения за LiveData объектами, не уведомляются об изменениях.

Простой пример может быть таким:

val data = MutableLiveData<String>("abc")

data.observe(this, Observer {
    val value = it ?: return@Observer
})

Вышеупомянутый наблюдатель будет продолжать отслеживать данные для обновлений всякий раз, когда активность/фрагмент переходит к onStart или onResume.

Теперь, что, если мы хотим отказаться от подписки наблюдателя после успешного обновления, отличного от null, и мы хотели бы иметь повторно используемый код? Давайте создадим функцию расширения:

fun <T> MutableLiveData<T>.observeOnce(lifecycleOwner: LifecycleOwner, observer: Observer<T>) {
    observe(lifecycleOwner, object : Observer<T> {
        override fun onChanged(t: T?) {
            observer.onChanged(t)
            if (t != null)
                removeObserver(this)
        }
    })
}

Итак, здесь мы наблюдаем за содержимым и удаляем наблюдателя при успешном ненулевом обновлении. Вы можете изменить этот метод расширения в соответствии с вашими потребностями.

Но если вы хотите что-то сделать и с нулевым значением, удалите if (t != null), и все готово.

Ваш код хотел бы этого, и вам не нужно проверять здесь нулевое значение, о котором уже позаботились в функции расширения:

val data = MutableLiveData<String>("abc")

data.observeOnce(this, Observer {
    print(it)
})

Надеюсь, вы нашли хороший обходной путь.

Удачного кодирования :)