首页 > 解决方案 > 如何在 RX 中进行顺序 API 调用

问题描述

我开始在 Android 上阅读有关 RX 的信息。我试图从 rx 链中进行 POST api 调用。我想看看这是否是正确的方法,我是否需要在拨打电话时再次创建一次性用品并再次注册订阅/观察线程。请查看代码中的注释。

disposable.add(module.getInfo()
.flatMapSingleElement {
  profile ->
    profile.getDetails().map {
      //IS THIS NEW DISPOSABLE NEEDED
      newDisposable.add(
    //Retrofit api to return Single<ResponseBody>
    //IS THIS THE RIGHT WAY TO MAKE A SEQUENTIAL API CALL IN RX CONSUMING DATA FROM ANOTHER OPERATOR
    module.saveImageDetails(
        ImageDetails(imageId)
        subscribeOn(Schedulers.io().observeOn(Schedulers.io())
            .subscribe(
                Consumer { handleResponse(it) },
                createErrorHandler()
            )
    )
      profile
    }
}
.subscribeOn(ioScheduler)
.observeOn(uiScheduler)
.subscribe(//do something)

标签: androidrx-javarx-java2rx-android

解决方案


推荐阅读