-
-
Save flyer88/e7a1841185a3758acd7bc68c0d7a8cd8 to your computer and use it in GitHub Desktop.
public interface Api{ | |
void queryPhoto(String query,QueryCallback QueryCallback); | |
void store(Photo photo,StoreCallback storeCallback); | |
interface QueryCallback{ | |
void onQuerySuccess(List<Photo> photoList); | |
void onQueryFailed(Exception e); | |
} | |
interface StoreCallback{ | |
void onCatStored(Uri uri); | |
void onStoredFailed(Exception 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<List<Photo>> storePhotoJob = new RxJob<Uri>() { | |
@Override | |
public void doJob(RxCallback<Uri> rxCallback) { | |
mApi.store(photo, new Api.StoreCallback() { | |
@Override | |
public void onCatStored(Uri uri) { | |
rxCallback.onNext(uri); | |
} | |
@Override | |
public void onStoredFailed(Exception e) { | |
rxCallback.onError(e); | |
} | |
}); | |
} | |
}; | |
queryPhotoJob.map(photoList -> { return getBestPhoto(photoList);}) | |
.flatMap(photo -> { return storePhotoJob;} ) | |
.map(photo -> {return photo.getUrl();}) | |
.doJob(new RxCallback<String>() { | |
@Override | |
public void onNext(String s) { | |
ToastUtils.show(s); | |
} | |
@Override | |
public void onError(Exception e) { | |
ToastUtils.show(e); | |
} | |
}); |
public abstract class RxJob<T>{ | |
public abstract void doJob(RxCallback<T> rxCallback){} | |
public RxJob map(){ | |
final RxJob<T> curJob = this; | |
return new RxJob<R>() { | |
@Override | |
public void doJob(final RxCallback<R> rxCallback) { | |
curJob.doJob(new RxCallback<T>() { | |
@Override | |
public void onNext(T t) { | |
R mapped = func.call(t); | |
rxCallback.onNext(mapped); | |
} | |
@Override | |
public void onError(Exception e) { | |
rxCallback.onError(e); | |
} | |
}); | |
} | |
}; | |
} | |
public RxJob flatMap(){...}; | |
} |
解释为什么 map
函数无法实现 flatMap
的功能?
flatMap
中的转变函数的具体实现是 T -> RxJob<R>
的转换
带入当前例子就是 Photo —> RxJob<String>
注意,之前的 map
方法是 List —> Photo
而不是 List<Photo> -> Photo
因为 map
方法的入参是 Func<T,R> func
,而不是 Func<List<T>,R> func
而 flaMap
函数的入参则是 Func<T,RxJob<R>> func
,写死了第二个参数类型必须是 RxJob<R>
,然后 RxJob<R>
方法会被执行
做到了异步中的异步,同样也说明了入参 Func<?,?> func
会决定转换函数的功能,从而影响整个变换的不同
map
和 flatMap
的区别就如下图
其核心在于类型的变换,即 Func<?,?> func
也就是函数式编程中的 Functor
不同的 func
就会实现不同的变换, flatMap
就是一个 Monad
当其运用到 ReactiveX 上时,其转换核心就是数据流,也就做到了 Observe/Subscribe
的模式,因为在每一次变换后数据始终存在,对应的操作也可触发。不过 RxJava
还有更多其他的东西,不仅仅是这两个变换。但基本上理解这两个变换就能举一反三了,理解其他变换
RxJava
中的 map/flatMap
也是创建对于的 Observable
对象,然后调用对应的函数,然后返回需要的数据
其中 map
方法中的入参 Function
,只会在各种类型中转换
而 flatMap
中的入参 Function
必然会转换出一个 Observable<R>
类型
在 RxJava 2
转换出的是一个 ObservableSource<R>
官方解释如下,non-backpressured Observable,可以理解为类似 Observable
类型,此处和 backpressured
的一些概念有关联,不作解释。
Represents a basic, non-backpressured {@link Observable} source base interface
==================================================================
参考文章:
给 Android
开发者的 RxJava
详解 作者:扔物线
========================================================
========================================================
最后
记录一些 RxJava
相关的文章内容
RxJava 中的 contactMap 和 flatMap 区别
========================================================
map
和flatMap
的对比flatMap
和map
最大的区别就是返还的RxJob
对象中curJob.doJob
中回调的区别flatMap
方法核心部分map
方法核心部分flatMap
在回调完以后,运行的是flatMapped.doJob()
并且把当前
RxJob
对象rxCallback
的回调放到了flatMapped.doJob
中的回调用从而使得下一个数据
r
是在运行完flatMapped
任务后生成的。代入此处就是
r
就是mApi.store(photo,callback)
中的photo