等待API调用以完成RxJava和Retrofit

我正在使用RxAndroid和RxJava和Kotlin向API发出各种请求,并以异步方式将其收回:

getClient().sendSomeData(data) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( { Log.i("upload", "data ok") }, { t -> Log.e("upload", "data error: " + t.stackTrace) } ); getClient().sendSomeOtherData(otherData) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( { Log.i("upload", "otherData ok") }, { t -> Log.e("upload", "data error: " + t.stackTrace) } ); 

等等。 现在我想要做的是,等待所有api请求完成并显示进度。 我如何等待所有可观察的事情完成并获得进展回调?

One Solution collect form web for “等待API调用以完成RxJava和Retrofit”

在这里和这里回答你的第一个问题,你会看到提到的Observable.onCompleted方法,这是成功的响应后调用。 这里也是这个方法的文档。 所以你可以简单地在subscribe方法调用中实现第三个Action并修改你的请求的状态信息。

如果涉及到请求进度状态,我不确定,但是我想RxJava并不提供这种function。 不过,我在这里find了答案(使用Retrofit库)。

Kotlin language will be the best programming language for Android.