admin管理员组文章数量:1642471
发射器Subscriber/Emitter，在Rxjava2之后，发射器改为了Emitter，他的作用主要是用来发射一系列事件的，比如next事件，complete事件等等。
有了这三个角色，一个完整的订阅关系也就生成了。
Observer处理完onComplete后会还能onNext吗?
要弄清楚这个问题，得去看看onComplete，onNext方法到底做了什么。
@Override
public void onComplete() {
if (!isDisposed()) {
try {
observer.onComplete();
} finally {
dispose();
}
}
}
@Override
public void onNext(T t) {
if (t == null) {
onError(new NullPointerException(“onNext called with null. Null values are generally not allowed in 2.x operators and sources.”));
return;
}
if (!isDisposed()) {
observer.onNext(t);
}
}
public static boolean isDisposed(Disposable d) {
return d == DISPOSED;
}
public static boolean dispose(AtomicReference field) {
Disposable current = field.get();
Disposable d = DISPOSED;
if (current != d) {
current = field.getAndSet(d);
if (current != d) {
if (current != null) {
current.dispose();
}
return true;
}
}
return false;
}
源码还是比较清晰明了，无论是onComplete还是onNext，都会判断当前订阅是否被取消，也就是Disposable类型的变量的引用是否等于DISPOSED，如果等于则代表该订阅已经被取消，起点和终点已经断开联系。而在onComplete方法的结尾调用了dispose方法，将原子引用类中的 Disposable对象设置为 DisposableHelper 内的 DISPOSED 枚举实例，即断开订阅关系，所以在这之后所有的onNext，onComplete，onError方法中的isDisposed判断都不会通过，也就不会执行后续的数据发送等处理了。
RxJava中的操作符
-
concatMap
-
flatMap
这两个操作符的功能是一样的，都是将一个发射数据的Observable变换为多个Observables，然后将它们发射的数据放进一个单独的Observable。区别在于concatMap是有序的，flatMap是无序的，concatMap最终输出的顺序与原序列保持一致，而flatMap则不一定，有可能出现交错。
举个例子，发送数字01234，通过操作符对他们进行+1处理，发送2的时候进行一个延时：
Observable.fromArray(1,2,3,4,5)
.flatMap(new Function<Integer, ObservableSource>() {
@Override
public ObservableSource apply(@NonNull Integer integer) throws Exception {
int delay = 0;
if(integer == 2){
delay = 500;//延迟发射
}
return Observable.just(integer*10).delay(delay, TimeUnit.MILLISECONDS);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
Log.e(“jimu”,“accept:”+integer);
}
});
如上述操作，最终打印结果为：10，20，40，50，30。因为发送数字2的时候，进行了延时。
但是如果flatMap操作符改成concatMap，打印结果就是10，20，30，40，50了，这是因为concatMap是有序的，会按照原序列的顺序进行变换输出。
- merge、concat、zip，合并
这几个操作符是用作合并发射物的，可以将多个Obserable和并成一个Obserable：
Observable odds=Observable.just(1,2,3,4);
Observable events=Observable.just(5,6,7,8);
Observable.merge(odds,events).subscribe(i->Log.d(“TAG”,“merge->”+i));
区别在于concat操作符是在合并后按顺序串行执行，merge操作符是在合并后按时间线并行执行，如果出现某个数据进行延时发射，那么结果序列就会发生变化。
而zip操作符的特点是合并之后并行执行，发射事件和最少的一个相同，什么意思呢？比如一个发送两个数据的Obserable和一个发射4条数据的Obserable进行zip合并，那么最终只会有两条数据被发射出来，看个例子：
Observable
.zip(Observable.just(1,2),Observable.just(3,4,5,6),new BiFunction<Integer, Integer, Integer>() {
@Override
public Integer apply(@NonNull Integer response, @NonNull Integer response2) throws Exception {
//将两个发射器的结果相加
return response+response2;
}
})
.subscribe(new Consumer() {
@Override
public void accept(@NonNull Integer s) throws Exception {
Log.e(“lz”,“accept+”+s);
}
});
结果只会有两条数据：4，6。第二个发射器发射的后面两条数据会被抛弃。
- interval，周期执行
这个操作符主要用作定时周期任务，比如我需要每100ms发送一次数据：
Observable.interval(100, TimeUnit.MILLISECONDS)
.subscribe(new Observer() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Long aLong) {
}
});
- timer，delay延迟发送数据
这两个操作符都是用作延时发送数据，不同在于timer是创建型操作符，而delay是辅助型操作符。意思就是timer操作符是可以直接创建一个Observable，然后在订阅之后延时发送数据项，看例子：
Observable
.timer(1000,TimeUnit.MILLISECONDS)
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数初中级Android工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则近万的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年Android移动开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Android开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注：Android）
总结
写到这里也结束了，在文章最后放上一个小小的福利，以下为小编自己在学习过程中整理出的一个关于Flutter的学习思路及方向，从事互联网开发，最主要的是要学好技术，而学习技术是一条慢长而艰苦的道路，不能靠一时激情，也不是熬几天几夜就能学好的，必须养成平时努力学习的习惯，更加需要准确的学习方向达到有效的学习效果。
由于内容较多就只放上一个大概的大纲，需要更及详细的学习思维导图的
还有高级UI、性能优化、架构师课程、NDK、混合式开发（ReactNative+Weex）微信小程序、Flutter全方面的Android进阶实践技术资料，并且还有技术大牛一起讨论交流解决问题。
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
养成平时努力学习的习惯，更加需要准确的学习方向达到有效的学习效果。
由于内容较多就只放上一个大概的大纲，需要更及详细的学习思维导图的
还有高级UI、性能优化、架构师课程、NDK、混合式开发（ReactNative+Weex）微信小程序、Flutter全方面的Android进阶实践技术资料，并且还有技术大牛一起讨论交流解决问题。**
[外链图片转存中…(img-VWCd1fSC-1712863038402)]
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
版权声明：本文标题：三个问题带你回顾安卓 RxJava基础，这个神奇又难用的框架 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/xitong/1729340606a1197490.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。
发表评论