rx-java – RxJava中的CompositeDisposable是什么

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

如果您需要提前处置(例如,用户导航远离活动),那么您需要这样做：

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())

然后你可以拨打一个处理电话：

composite.dispose()

如果您使用的是kotlin,您可以使用运算符重载来使其看起来更好：

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的方法来处理请求.