RxJava2.0中如何处理disposable

Question

我是 Rx 世界的新手，我见过多个如何处理 Disposable 的示例，但我不太了解其中的区别。我正在使用 RxJava 2.0 (v2.2.17) 和 RxAndroid (v2.1.1)。

我的问题是 case 1 和 case 2 有什么区别？在您的应用程序中更喜欢这两种情况中的哪一种？

案例 1：

private val compositeDisposable: CompositeDisposable = CompositeDisposable()

adsApiService.getVideos()
        .subscribeOn(Schedulers.io())
        .observeOn( AndroidSchedulers.mainThread())
        .subscribe(
            { v -> Log.d("video", v.toString()) },
            { e -> Log.d("video", e.toString()); compositeDisposable.dispose() },
            { compositeDisposable.dispose() },
            { disposable -> compositeDisposable.add(disposable)}
        )
}

案例 2：

class MainActivity : AppCompatActivity() {

    private var compositeDisposable: CompositeDisposable? = CompositeDisposable()

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

        compositeDisposable?.add(api.getVideosAds())
    }

    override fun onDestroy(){
        super.onDestroy()
        compositeDisposable?.dispose()
    }

}

Answer 1

个人？两者都没有。

您应该学习如何使用ViewModels，并保留您的CompositeDisposable，并在onCleared() 方法中清除它。

另外，你的例子也有一些问题：

案例 1

你应该简单地将一次性添加到compositeDisposable，不知道为什么你将额外的 2 个 lambdas 传递给subscribe：

compositeDisposable += adsApiService.getVideos()
  .subscribeOn(Schedulers.io())
  .observeOn( AndroidSchedulers.mainThread())
  .subscribe(
    { v -> Log.d("video", v.toString()) },
    { e -> Log.d("video", e.toString()) }
  )

在这种情况下，您实际上并没有正确清除 compositeDisposable，因为它没有附加到任何生命周期（Activity、Fragment 或 ViewModel）

案例 2

语句中不需要问号：

private var compositeDisposable: CompositeDisposable? = CompositeDisposable()

这个例子在语义上是正确的，尽管api 应该隐藏在ViewModel（MVVM 架构）或Presenter（MVP 架构）或任何架构中。将所有内容都放在视图类 (MainActivity) 中是一种糟糕的做法，而且很难维护。