代码之家 › 专栏 › 技术社区 › ir2pid

使用复合包装的最佳实践是什么?

rx-java2 retrofit2 rx-java retrofit android

ir2pid · 技术社区 · 6 年前

                               observable.......
                               .subscribe(
                                {
                                    utilModule.logI("net repo response")
                                    //cleanDisposables()//this causes HttpOk cancelled error
                                },
                                {
                                    utilModule.logI("no repo response" + it.message)
                                    //cleanDisposables()
                                }
                        ))
    }

    private fun cleanDisposables() {
        //clean old network observables, dispose will prevent further observing
        utilModule.logI("disposing observables")
        if (!compositeDisposables.isDisposed) {
            compositeDisposables.clear()
        }
    }

2 回复 | 直到 6 年前

tgrable 6 年前

这可能是一个使用MVP设计模式的例子…

presenter.kt
fun dispose() {
    compositeDisposable.clear()
}


activity.kt
override fun onDestroy() {
    super.onDestroy()
    presenter.dispose()
}

Stefano Mtangoo 6 年前

CompositeDisposable .我愿意 clear onCleared 方法。

public class MyViewModel extends AndroidViewModel {
    private MyRepo mRepo;
    private CompositeDisposable mDisposables = new CompositeDisposable();


    public MyViewModel(@NonNull Application application) {
        super(application);

        mRepo = MysRepo.getInstance(...);
    }

    public void loadData()
    {
        Disposable d = mRepo.getMyPeculiarData()
                ...
                .subscribe(...);

        mDisposables.add(d);
    }


    @Override
    protected void onCleared() {
        super.onCleared();
        mDisposables.clear();
    }

}

推荐文章

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

6 年前

Myk Willis · 将具有指定泛型列表类型的Observable作为方法参数传递

6 年前

Mangat Rai Modi · 垂直。x反应式卡夫卡客户端:编写时链接不起作用?

6 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

6 年前

Jhon Fredy Trujillo Ortega · 如何在平面图中使用等待方法?

6 年前

casolorz · 可合成。清除导致OkHttp抛出java。lang.IllegalStateException:输入/退出不平衡

6 年前

O10 · 与observeOn组合时,RxJava启动时忽略运算符

6 年前

ddinchev · RxJava2并行执行一组completable并等待全部完成

6 年前

advice · RxJava-捕获使用者异常

6 年前

Daksh · 条件链单链和完全链

6 年前