android - RxJava调用一次性dispose()

我正在使用rxjava进行改造。在以下代码中，subscribeOn（）和observeOn（）继续运行。该应用程序会自行终止并不断启动。

disposable = api.getUsers("135")
                .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({
                users -> showResult(users)
            })

如果我在上述操作之后立即进行处理，它将无法获取完整的数据。所以我的问题是何时处置可分配性或如何知道subscribeOn（）和observeOn（）完成任务的时间。

最佳答案

您可以在dispose的onDestroy()中Activity。

或者也可以使用DisposableSingleObserver像这样：

Disposable disposable = yourApi.subscribeWith(new DisposableSingleObserver<List<String>>() {

        @Override
        public void onSuccess(List<String> values) {
            // work with the resulting values
        }

        @Override
        public void onError(Throwable e) {
            // handle the error case
        }
    });

  然后使用结果后（在本示例中为当您不再需要值（api响应）时，可以调用dispose

    disposable.dispose();

放置观察者的最佳位置是onDestory()，这将是您不再需要api结果的地方：

protected void onDestroy(){
    super.onDestroy();
    disposable.dispose();
}