如何创建发出单个事件并仅通知最后订阅的观察者的 LiveData?

The*_*olf 7 android android-livedata android-architecture-components android-jetpack

我创建了实时数据,它发出单个事件,如本例所示

接下来我的问题是:当 LiveData 中的值发生变化时,如何仅通知最后订阅的观察者?

我想到的是将观察者存储在 SingleLiveData 类的链表中,然后super.observe仅当传递的观察者与列表的最后一个元素相同时才调用。

我不确定这是否是最好的方法。

我想使用这种机制将 FAB 单击事件从活动传播到 ViewPager 内部显示的片段。片段是动态添加到视图寻呼机适配器的,所以假设我们知道片段的顺序。

The*_*olf 10

最后,我找到了解决此问题的方法。我不得不远离发出单个事件的实时数据,因为它无法按照我需要的方式运行。

取而代之的是,我使用了简单的可变实时数据,它发出一个事件对象,该对象包装数据,如Jose Alcérreca 撰写的本文的最后一段。

我在视图寻呼机中显示片段,所以我当时只有一个可见片段。

所以我的视图模型如下所示:

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)
  }
}
Run Code Online (Sandbox Code Playgroud)

事件包装器类实现如下所示:

/*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
}
Run Code Online (Sandbox Code Playgroud)

现在我们可以在片段中观察这样的事件:

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
         }
       })
}
Run Code Online (Sandbox Code Playgroud)

如果片段当前对用户可见,则片段userVisibleHint属性将返回 true。由于我们当时只显示一个片段,这对我们有用。这意味着片段只会访问可见的事件数据。

此外,事件包装器的实现只允许读取一次值,因此每次 Observer 获取此事件时,其值为 null,我们将忽略它。

结论:通过这种方式,我们模拟了单个事件实时数据,该数据仅通知最后订阅的观察者。