Как создать LiveData, который генерирует одно событие и уведомляет только последнего подписанного наблюдателя?

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

Вместо этого я использовал простые изменяемые оперативные данные, которые создают объект события, который оборачивает данные, как в последнем абзаце этого статья Хосе Альсеррека.

Я показываю фрагменты в пейджере, поэтому в данный момент у меня есть только один видимый фрагмент.

Итак, моя модель представления выглядит так:

class ActionViewModel : ViewModel() {
  private val onCreateLiveData: MutableLiveData<Event<String>> = MutableLiveData()

  fun observeOnCreateEvent(): LiveData<Event<String>> = onCreateLiveData

  fun onCreateCollectionClick(message: String) {
    this.onCreateLiveData.value = Event(message)
  }
}

Реализация класса-обертки событий выглядит так:

/*Used as a wrapper for data that is exposed via a LiveData that represents an 
 event.*/

open class Event<out T>(private val content: T) {

  var hasBeenHandled = false
    private set // Allow external read but not write

  /**
   * Returns the content and prevents its use again.
  */
  fun getContentIfNotHandled(): T? {
    return if (hasBeenHandled) {
      null
    } else {
      hasBeenHandled = true
      content
    }
  }

  /**
    * Returns the content, even if it's already been handled.
  */
  fun peekContent(): T = content
}

Во фрагментах теперь мы можем наблюдать такие события:

override fun onActivityCreated(savedInstanceState: Bundle?) {
   super.onActivityCreated(savedInstanceState)

   actionViewModel = ViewModelProviders.of(requireActivity()).get(ActionViewModel::class.java)
   actionViewModel.observeOnCreateEvent()
       .observe(this, Observer {
         it?.takeIf { userVisibleHint }?.getContentIfNotHandled()?.let {
           //DO what ever is needed
         }
       })
}

Свойство фрагмента userVisibleHint возвращает значение true, если фрагмент в данный момент виден пользователю. Поскольку мы показываем только один фрагмент за раз, это работает для нас. Это означает, что фрагмент будет получать доступ к данным события только в том случае, если он виден.

Кроме того, реализация оболочки Event позволяет только одно чтение значения, так что каждый следующий раз, когда Observer получает это событие, его значение будет нулевым, и мы его проигнорируем.

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

Я разработал решение, не стесняйтесь взглянуть на https://github.com/ueen/LiveEvent

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

Миграция описана здесь среди других мест. Вот простой пример:

ViewModel:

interface MyViewModel {
    val myData: StateFlow<MyData>
    val myEvents: SharedFlow<MyEvent>
}

class MyViewModelImpl: MyViewModel {
    override val myData = MutableStateFlow(MyData())
    override val myEvents = MutableSharedFlow<MyEvent>(replay = 0, extraBufferCapacity = 1, BufferOverflow.DROP_OLDEST)

    /*
     * Do stuff 
     */
}

Мероприятия:

lifecycleScope.launch {
    myData.collect {
        // handle stateful data    
    }
}

lifecycleScope.launch {
    myEvents.collect {
        // handle stateless events    
    }
}

Обратите внимание, что для lifecycleScope требуется соответствующая ktx-зависимость.

Герер еще немного читает о Flow в Android.