LiveData 在第一次回调后删除观察者

收到第一个结果后如何删除观察者？下面是我尝试过的两种代码方式，但即使我删除了观察者，它们仍然会不断接收更新。

Observer observer = new Observer<DownloadItem>() {
        @Override
        public void onChanged(@Nullable DownloadItem downloadItem) {
            if(downloadItem!= null) {
                DownloadManager.this.downloadManagerListener.onDownloadManagerFailed(null, "this item already exists");
                return;
            }
            startDownload();
            model.getDownloadByContentId(contentId).removeObservers((AppCompatActivity)context);
        }
    };
    model.getDownloadByContentId(contentId).observeForever(observer);

 model.getDownloadByContentId(contentId).observe((AppCompatActivity)context, downloadItem-> {
             if(downloadItem!= null) {
                this.downloadManagerListener.onDownloadManagerFailed(null, "this item already exists");
                return;
            }
            startDownload();
            model.getDownloadByContentId(contentId).removeObserver(downloadItem-> {});
        } );

对于带有扩展的 Kotlin 有一个更方便的解决方案：

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

这个扩展允许我们这样做：

liveData.observeOnce(this, Observer<Password> {
    if (it != null) {
        // do something
    }
})

因此，为了回答您原来的问题，我们可以这样做：

val livedata = model.getDownloadByContentId(contentId)
livedata.observeOnce((AppCompatActivity) context, Observer<T> {
    if (it != null) {
        DownloadManager.this.downloadManagerListener.onDownloadManagerFailed(null, "this item already exists");
    }
    startDownload();
})

原始来源在这里：https://code.luasoftware.com/tutorials/android/android-livedata-observe-once-only-kotlin/ https://code.luasoftware.com/tutorials/android/android-livedata-observe-once-only-kotlin/

更新：@Hakem-Zaied 是对的，我们需要使用observe代替observeForever.