如何实现 RxJava 的链式调用 -- map 方法的实现

Api.java

public interface Api{
    void queryPhoto(String query,QueryCallback QueryCallback);
    interface QueryCallback{
        void onQuerySuccess(List<Photo> photoList);
        void onQueryFailed(Exception e);
    }
}

PhotoUtils.java

public class PhotoUtils{
    Api mApi;
    public void handlePhotoSync(){
        mApi.queryPhoto("flyer", new Api.QueryCallback() {
            @Override
            public void onQuerySuccess(List<Photo> photoList) {
                Photo photo = getBestPhoto(photoList);
              	String imgUrl = photo.getUrl();
            }

            @Override
            public void onQueryFailed(Exception e) {
				ToastUtils.show(e);
            }
        });
    }
}

整个任务如何运行

RxJob<List<Photo>> queryPhotoJob = new RxJob<List<Photo>>(){
  				@Override
                public void doJob(final RxCallback<List<Photo>> rxCallback) {
                    mApi.queryPhoto("flyer", new Api.QueryCallback() {
                        @Override
                        public void onQuerySuccess(List<Photo> photoList) {
                            rxCallback.onNext(photoList);
                        }
                      

                        @Override
                        public void onQueryFailed(Exception e) {
                            rxCallback.onError(e);
                        }
                    });
                }
            };
};
RxJob<Photo> bestPhotoJob = queryPhotoJob.map(photoList -> { return getBestPhoto(photoList);})
RxJob<String> urlJob = .map(photo -> {return photo.getUrl();})
urlJob.doJob(new RxCallback<String>() {
            @Override
            public void onNext(String s) {
				ToastUtils.show(s);
            }

            @Override
            public void onError(Exception e) {
				...
            }
   });

解释代码，第一个 map 方法 返还了一个 RxJob<Photo> 对象，第二个 map 返还了一个 RxJob<String> 对象，第三个 doJob 方法触发整个任务

doJob 方法触发的第一个方法是 urlJob 中的 doJob 方法，由于 urlJob 对象是由 map 方法创建的

因此，在执行 ToastUtils.show(s) 方法之前，会先执行 bestPhotoJob.doJob()

同样，queryPhotoJob.doJob()也会执行在 bestPhotoJob.doJob() 方法之前

因此整体过程就是 queryPhotoJob.doJob() —> bestPhotoJob.doJob() —> urlJob.doJob()

而这执行过程中，R mapped = func.call(T) 会先被调用，因此单个 RxJob 调用链如下：

在调用每个 RxJob.onNex()情况下(即成功的情况下，没有出错)

queryPhotoJob.doJob() : mApi.query —> func.call(t) —> getBestPhoto(photoList)

bestPhotoJob.doJob() ： func.call(t) —> photo.getUrl()

urlJob.doJob()： ToastUtil.show()

比较炫酷的写法如下：

RxJob<List<Photo>> queryPhotoJob = new RxJob<List<Photo>>(){
  				@Override
                public void doJob(final RxCallback<List<Photo>> rxCallback) {
                    mApi.queryPhoto("flyer", new Api.QueryCallback() {
                        @Override
                        public void onQuerySuccess(List<Photo> photoList) {
                            rxCallback.onNext(photoList);
                        }
                      

                        @Override
                        public void onQueryFailed(Exception e) {
                            rxCallback.onError(e);
                        }
                    });
                }
            };
};
queryPhotoJob
  .map(photoList -> { return getBestPhoto(photoList);})
  .map(photo -> {return photo.getUrl()})
  .doJob(...);

=================================

异步里面还有异步方法，flatMap 待续

=================================