android - RxJava 中的 CompositeDisposable 是什么

Question

我是一名 Android 学生。我想学习 RxJava。我的问题是“RxJava 中的 CompositeDisposable 是什么？”。请详细描述。

Answer 1

一次性复合 Material 使处置(考虑提前取消)更容易。假设您有一个同时发生多个 api 调用的 Activity :

var disposable = api.call1(arg1, arg2).subscribe(...)
var disposable2 = api.call2(arg1).subscribe(...)
var disposable3 = api.call3().subscribe()

如果您需要提前处置(例如，用户离开 Activity )，那么您需要这样做:

disposable.dispose()
disposable2.dispose()
disposable3.dispose()

如果您改为使用 CompositeDisposable，您可以将所有一次性用品存储在其中。像这样:

val composite = CompositeDisposable()
composite.add(api.call1(arg1, arg2).subscribe(...))
composite.add(api.call2(arg1).subscribe(...))
composite.add(api.call3().subscribe())

然后您可以进行一次 dispose 调用:

composite.dispose()

如果您使用的是 kotlin，您可以使用运算符重载来使这看起来更好:

operator fun CompositeDisposable.plusAssign(disposable: Disposable) {
    this.add(disposable)
}

这使您可以将其表达为:

val composite = CompositeDisposable()
composite += api.call1(arg1, arg2).subscribe(...)
composite += api.call2(arg1).subscribe(...)
composite += api.call3().subscribe()

Disposable 表示一个请求(认为工作正在完成)，并且有一个称为 dispose 的方法来处理该请求。