使用RxJava和Retrofit链接两个Web服务调用

Question

我正在使用RxJava和Retrofit.我的基本要求是,我想链接两个api调用,这将被一个接一个地调用.从第一个api收到的响应在调用第二个api时用作输入.在互联网上阅读了一些东西之后我习惯了flatmap来实现这个目标.在执行此操作时,我正在显示装载器.有时它运行顺利但在某些情况下这个装载机冻结.DDMS显示"跳过300帧,应用程序可能在其主线程上做了太多工作"的日志.我怀疑我的一个网络调用正在主线程上运行.我无法弄清楚如何链接这两个调用,以便可以在后台顺利调用它们而不会妨碍我的主线程.任何帮助是极大的赞赏 .提前谢谢这是我到目前为止所尝试的

private CompositeSubscription mSubscriptions = new CompositeSubscription();

Subscription subscription = Observable.just(getAddress())
          .subscribeOn(Schedulers.newThread())
          .flatMap(address -> mPlatformApi.secondWebService(address.getLatitude(),address.getLongitude())
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe(modelTwo ->
          {
            //updating My ui
          }, throwable -> {

            //Error Handling
          });

mSubscriptions.add(subscription);


private android.location.Address getAddress(){
    String addressString = "";//some Address String
    Geocoder coder = new Geocoder(getActivity());
    android.location.Address address=null;
    try {
      ArrayList<android.location.Address> addressList = (ArrayList<android.location.Address>) coder.getFromLocationName(addressString, 1);
      if(addressList !=null && addressList.size()>0) {
        address = addressList.get(0);
      } else {

      }
    } catch (IOException e) {
      e.printStackTrace();
    }
    return address;
  }

//My Retrofit call
Observable<modelTwo> secondWebService(@Path("lat") double lat,@Path("lon") double lon);

Answer 1

考虑一下:

final android.location.Address address = getAddress();
Subscription subscription = Observable.just(address) ...

这相当于您的代码,但也应该明确在RxJava参与之前getAddress()进行评估并且有任何机会进行干预.换句话说,当你使用时just,subscribeOn只能将地址(呼叫你)的发射移动到另一个线程.但是,当你到达这一点时,地址的创建 - 也就是你的- 将在主线程上发生.onNext(address)SubscribergetAddress

实际移动getAddress到另一个线程的最简单方法是使用defer:

Subscription subscription = Observable.defer(new
          Func0<Observable<android.location.Address>>() {

              @Override
              public Observable<android.location.Address> call() {
                  return Observable.just(getAddress());
              }
          })
          .subscribeOn(Schedulers.newThread())
          .flatMap(address -> mPlatformApi.secondWebService(address.getLatitude(),address.getLongitude()    )
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe(modelTwo ->
          {
            //updating My ui
          }, throwable -> {
            //Error Handling
          });

这样,整个Func0将被执行newThread()- 不仅是just而且还有getAddress.