2b0f4108a645

很赞，，很清晰，边看边写列子运行看效果，

给初学者的RxJava2.0教程(六)

Outline [TOC] 前言 在上一节中, 我们找到了上下游流速不均衡的源头 , 在这一节里我们将学习如何去治理它 . 可能很多看过其他人写的文章的朋友都会觉得只有F...

Season_zlc

41316 91 399 11

2b0f4108a645

Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
}
}).concatMap(new Function<Integer, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(Integer integer) throws Exception {
final List<String> list = new ArrayList<>();
for (int i = 0; i < 3; i++) {
list.add("I am value " + integer);
}
return Observable.fromIterable(list).delay(10, TimeUnit.MILLISECONDS);
}
}).subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.d(TAG, s);
}
});

hi，楼主，这段代码我运行出来的结果，是有序的，结果显示的是
04-05 10:53:26.013 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 1
04-05 10:53:26.013 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 1
04-05 10:53:26.013 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 1
04-05 10:53:26.025 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 2
04-05 10:53:26.025 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 2
04-05 10:53:26.025 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 2
04-05 10:53:26.033 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 3
04-05 10:53:26.033 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 3
04-05 10:53:26.033 12166-13590/com.xszhang.mvptest D/MainActivity: I am value 3
我尝试了concatMap 和flatMap 都是有序的 ，也就是说，你上面描述的这段文字 “上游每发送一个事件, flatMap都将创建一个新的水管, 然后发送转换之后的新的事件, 下游接收到的就是这些新的水管发送的数据. 这里需要注意的是, flatMap并不保证事件的顺序, 也就是图中所看到的, 并不是事件1就在事件2的前面” ，是有问题的。还请楼主解答，谢谢！

给初学者的RxJava2.0教程(三)

Outline [TOC] 前言 上一节讲解了线程调度, 并且举了两个实际中的例子, 其中有一个登录的例子, 不知大家有没有想过这么一个问题, 如果是一个新用户, 必须先注册...

Season_zlc

87123 194 627 15

2b0f4108a645

楼主，其实我还有一个问题，就是为什么要用rxjava呢？它让我们选择它的理由是啥？仅仅就是代码节减，融入了 异步 和链式操作？

给初学者的RxJava2.0教程(一)

Outline [TOC] 前言 上个月RxJava2正式版发布了，但目前国内的资料还比较少，以前使用过RxJava1只需要看看更新文档就知道怎么使用了，但还有一些以前没用过...

Season_zlc

262892 312 2089 49

2b0f4108a645

写的通俗易懂，对于新手入门有很大的帮助 ，赞一个，支持原创

给初学者的RxJava2.0教程(一)

Outline [TOC] 前言 上个月RxJava2正式版发布了，但目前国内的资料还比较少，以前使用过RxJava1只需要看看更新文档就知道怎么使用了，但还有一些以前没用过...

Season_zlc

262892 312 2089 49