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

Question

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

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-> {});
        } );

Answer 1

对于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/

更新:@hakem-zaied是对的，我们需要使用observe而不是observeForever。

Answer 2

您的第一个将不起作用，因为observeForever()没有绑定到任何LifecyCleOwner。

您的第二个将不起作用，因为您没有将现有的已注册观察者传递给removeobserver()。

您首先需要确定是否将LiveData与LifecycleOwner（您的activity）一起使用。我的假设是，您应该使用lifecycleowner。在这种情况下,请使用：

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).observe((AppCompatActivity)context, observer);