我对 rxjava 很陌生,刚刚开始学习它并将我们的 android 项目转换为 rx。因此,我编写了可观察量,并使用平面图将它们链接起来,以调用 api 并返回可观察量。现在,在主要 Activity 中,我订阅它们,并将我的 UI 代码添加到 onNext、onSubscribe、onComplete 和 onError(如果适用)。但是我有多个 api,我为每个 api 创建了一个可观察的对象,但我想在订阅它们的观察者上有一个包装器。主要是执行一段代码,比如记录 onNext/onError 调用,在 onSubscribe 上显示进度状态,在 onComplete/onError 上关闭它等。
除了每次添加它或每次都有一个baseobserver并添加super.method(人们可能会忘记super.method,因此我猜应该从 Activity 代码中删除此处理)之外,我该如何做到这一点
这个想法是实现一个BaseActivity
,所有其他 Activity 都从它扩展而来。在此 Activity 中,您声明通用 Observer
,当从此类扩展时,您将获得该 Observer,并且可以根据需要进行自己的修改。看看这个code
我是一名优秀的程序员,十分优秀!