我见过的讲述RxJava很到位的一篇文章
我不喜欢抄袭，转载，贴上链接。
RxJava 简述一下，RxJava相当于Java版本的Promise，大大增强了异步的可读性。
其他也无多说，贴上RxJava实现图片后台上传回调。
//图片地址储存
private ArrayList<String> dataList;
//回调事件定义（订阅者）
private Subscriber<String> stringSubscriber=new Subscriber<String>() {
@Override
public void onCompleted() {
//完成操作（异步的同步需求，见node 的同步实现）
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
File toUpload=new File(s);
final String key=HttpHelper.generateKey(user_id,toUpload);
dataList.set(dataList.indexOf(s),key);
final MultipartRequest multipartRequest= RequestFactory.uploadImg(
key,
ImageCompressor.compreeImageFile(getBaseContext(),toUpload),
new RequestCallback() {
@Override
public void successCallback(String response) {
Log.d("123",response);
}
@Override
public void failCallback(VolleyError error){
}
@Override
public void processCallback() {
}
});
myVolleySingleton.addToRequestQueue(multipartRequest);
}
};
//添加观察者
rx.Observable.from(dataList).observeOn(AndroidSchedulers.mainThread()).subscribe(stringSubscriber);
摘录一段关于关于Sechduler的介绍，十分重要。
在RxJava 中，Scheduler ——调度器，相当于线程控制器，RxJava 通过它来指定每一段代码应该运行在什么样的线程。RxJava 已经内置了几个 Scheduler
，它们已经适合大多数的使用场景：
Schedulers.immediate(): 直接在当前线程运行，相当于不指定线程。这是默认的 Scheduler。
Schedulers.newThread(): 总是启用新线程，并在新线程执行操作。
Schedulers.io(): I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler。行为模式和 newThread() 差不多，区别在于 io()
的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io()
中，可以避免创建不必要的线程。
Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。不要把 I/O 操作放在 computation() 中，否则 I/O 操作的等待时间会浪费 CPU。
另外， Android 还有一个专用的 AndroidSchedulers.mainThread()
，它指定的操作将在 Android 主线程运行。
以上。
