摘要:开始前上节初步了解了,本节主要讲讲的操作符。那本节就根据图书上操作符的描述,根据操作符类型分类分别介绍一些操作符的使用。操作符行为类似于,但是只有当原始的中的每一个都发射了一条数据时才发射数据。通过流水线的传递最终到达消费者手中。
开始前
上节初步了解了RxJava,本节主要讲讲RxJava的操作符。官方文档中可以看到操作符特别的多,同样也是RxJava比较重要的内容,在我看来灵活使用RxJava离不开对它的操作符的理解。那本节就根据图书《RxJava Essentials》上操作符的描述,根据操作符类型分类分别介绍一些操作符的使用。另外本节引用了RxJava-Android-Samples一些实例更好理解操作在实际开发中如何使用。
Filtering Observables
take
发射事件流中的前n个事件
Observable.just(1,2,3,4,5,6,7,8,9,10) //只取前4个事件 1,2,3,4 .take(4) .subscribe(...)
takeLast
发射事件流中的后n个事件
Observable.just(1,2,3,4,5,6,7,8,9,10) //只取4个事件 7,8,9,10 .takeLast(4) .subscribe(...)
distinct
过滤事件流重复发射的事件
Observable.just(1,2,3,3,2,3,2,4,5,4,5,5) //只取5个事件 1,2,3,4,5 .distinct() .subscribe(...)
distinctUntilChange
过滤一样的事件直到事件发生变化才进行发射
Observable.just(1,2,2,3,3,4,4,4,5,5) //只取5个事件 1,2,3,4,5 .distinct() .subscribe(...)
repeat
重复发射事件流
Observable.just(1,2,3) .repeat(3) .subscribe(...) //订阅获取 1,2,3,1,2,3,1,2,3
first
发射首个事件
Observable.just(1,2,3) .first() .subscribe(...) //订阅获取 1
last
发射最后一个事件
Observable.just(1,2,3) .last() .subscribe(...) //订阅获取 1
skipLast
跳过发射事件流后n个事件
Observable.just(1,2,3,4,5,6,7,8,9,10) .skipLast(4) .subscribe(...) //订阅获取 1,2,3,4,5,6
timeout
不发射超出指定时间内外的事件
Observable.create(new Observable.OnSubscribe() { @Override public void call(Subscriber super Integer> subscriber) { subscriber.onNext(1); subscriber.onNext(2); subscriber.onNext(3); deplyTime();//延迟 subscriber.onNext(4); subscriber.onNext(5); } }) .timeout(2, TimeUnit.SECONDS) .subscribe(...) //订阅获取 1,2,3
sample
发射在指定时间内事件流中的最后一个事件
Observable.create(new Observable.OnSubscribe() { @Override public void call(Subscriber super Integer> subscriber) { subscriber.onNext(1); subscriber.onNext(2); subscriber.onNext(3); deplyTime(); subscriber.onNext(4); subscriber.onNext(5); deplyTime(); subscriber.onNext(6); } }) .sample(2,TimeUnit.SECONDS) .subscribe(...) //订阅获取 3,5,6
throttleFirst
发射在指定时间内事件流中的第一个事件
Observable.create(new Observable.OnSubscribe() { @Override public void call(Subscriber super Integer> subscriber) { subscriber.onNext(1); subscriber.onNext(2); subscriber.onNext(3); deplyTime(); subscriber.onNext(4); subscriber.onNext(5); deplyTime(); subscriber.onNext(6); } }) .throttleFirst(2,TimeUnit.SECONDS) .subscribe(...) //订阅获取 1,4,6
debounce
在计时时间内事件流没有产生新事件则发射当前事件,若有新事件产生则重新计时
Observable.create(new Observable.OnSubscribe() { @Override public void call(Subscriber super Integer> subscriber) { subscriber.onNext(1); subscriber.onNext(2); deplyTime();//延时两秒 subscriber.onNext(3); subscriber.onNext(4); subscriber.onNext(5); deplyTime(); deplyTime(); subscriber.onNext(3); subscriber.onNext(4); deplyTimeLittle();//延时一秒 subscriber.onNext(5); subscriber.onNext(4); deplyTimeLittle(); subscriber.onNext(7); deplyTime(); subscriber.onNext(6); } }) .debounce(2,TimeUnit.SECONDS) .subscribe(...) //订阅获取 2,5,7,6
实例应用:监听EditTextView字符变化,在输入字符后400ms内无变化则订阅字符串事件
_subscription = RxTextView.textChangeEvents(_inputSearchText) .debounce(400, TimeUnit.MILLISECONDS)// default Scheduler is Computation .filter(changes -> isNotNullOrEmpty(_inputSearchText.getText().toString())) .observeOn(AndroidSchedulers.mainThread()) .subscribe(_getSearchObserver());Transforming Observables
flatMap
faltMap用法和map类似但flatMap返回的是Observable对象,另外flatMap支持无序,最后订阅的事件流并不一定和原来的序列保持一致。
concatMap
concatMap用法和flatMap一样,只是concatMap能够保证事件流保持原来的序列。
flatMapIterable
flatMapIterable和faltMap类似,但返回类型是Iterable
switchMap
scan
获取当前事件和后一个事件做特殊处理返回同类型事件,主要应用对事件的包装。
groupBy
对事件进行分类订阅,根据自定义筛选规则对事件流分类,通过GroupedObservable.getKey()区分处理事件。
Observable.just(1,2,3,4,5,6,7,8,9,10) .groupBy(new Func1() { @Override public Boolean call(Integer integer) { return integer % 2 == 0; } }).subscribe(new Action1 >() { @Override public void call(GroupedObservable booleanIntegerGroupedObservable) { if(booleanIntegerGroupedObservable.getKey()){ //True booleanIntegerGroupedObservable.subscribe(new Action1 () { @Override public void call(Integer integer) { Log.i("Subscriber true",integer + " "); } }); }else{ //False booleanIntegerGroupedObservable.subscribe(new Action1 () { @Override public void call(Integer integer) { Log.i("Subscriber false",integer + " "); } }); } } }); //订阅结果 1,3,5,7,9由false处理,2,4,6,8,10由true处理
buffer
将事件流组装为数组发射,大小由Buffer决定
Observable.just(1,2,3,4,5,6,7,8,9,10) .buffer(3) .subscribe(...) //订阅获取 [1, 2, 3],[4, 5, 6],[7, 8, 9],[10]
实例应用:点击事件,buffer做定时组装数组,计时时间内无新事件产生则组装当前数组发射
RxView.clickEvents(_tapBtn) .map(onClickEvent -> { Timber.d("--------- GOT A TAP"); _log("GOT A TAP"); return 1; }) .buffer(2, TimeUnit.SECONDS) .observeOn(AndroidSchedulers.mainThread()) .subscribe(...);
window
window操作符会在时间间隔内缓存结果,类似于buffer缓存一个list集合,区别在于window将这个结果集合封装成了observable
bservable.interval(1,TimeUnit.SECONDS) .take(10) .window(3,TimeUnit.SECONDS) .subscribe(...)
cast
设置事件的指定类型Combining Observables
merge
合并事件流,用法和groupBy恰恰相反
Observable.merge(Observable.just(2,3),Observable.just(3,5)) .subscribe(...); //订阅获取 2,3,3,5
zip
整合多个事件流将事件结果整合处理再发射事件
Observable.zip(Observable.just(1, 2, 3), Observable.just(1, 2, 3), new Func2() { @Override public Integer call(Integer integer, Integer integer2) { return integer + integer2; } }) .subscribe(...) //订阅结果 2,4,6
实战应用:两个http请求并发,等待两个结果返回再处理结果实现多次请求一次处理
Observable.zip( service.getUserPhoto(id), service.getPhotoMetadata(id), (photo, metadata) -> createPhotoWithData(photo, metadata)) .subscribe(photoWithData -> showPhoto(photoWithData));
join
join同样是将多个事件流结果合并统一处理,当join可控制每个事件流结果生命周期,,在每个结果的生命周期内,可以与另一个Observable产生的结果按照一定的规则进行合并。
combineLatest
CombineLatest操作符行为类似于zip,但是只有当原始的Observable中的每一个都发射了一条数据时zip才发射数据。CombineLatest则在原始的Observable中任意一个发射了数据时发射一条数据。当原始Observables的任何一个发射了一条数据时,CombineLatest使用一个函数结合它们最近发射的数据,然后发射这个函数的返回值。关于Java8 Lambda
本节一些地方引用的例子使用了函数式编程写法,这是Java SE 8中一个重要特性。这里稍微做一个简短的Lambda介绍。
Lambda表达式是Java SE 8中一个重要的新特性。lambda表达式允许你通过表达式来代替功能接口。 lambda表达式就和方法一样,它提供了一个正常的参数列表和一个使用这些参数的主体(body,可以是一个表达式或一个代码块)。Lambda表达式还增强了集合库。
lambda的确让Java代码紧凑简洁,可并行处理集合例如filter、map、reduce等并行函数。但目前看来据我所知使用Lambda的程序员不是大多数,Lambda也降低了代码的可读性在开发企业项目不易于维护开发,但不妨先学习了解。
回想在学习RxJava的过程中我对于RxJava有了自己的理解,找了一张来自泡在网上的日子的一张图。整个RxJava被订阅的过程是一个Subscription可以比喻成工厂生产商品到消费者的过程,产品最终是否可以到达消费者手中由Subscription决定,observable可以理解成未加工过的产品(至少在为被Subscriber消费之前是的),Operations为整个生产线上每一条流水线。Schers为一个车间,它代表着Operation在哪车间里运作。Observable通过流水线的传递最终到达消费者Subscer手中。这个过程就像是给一个初始的产品模型在生产制作过程当中不断加工制作组装,最终达到消费者手中是一个制作加工所想要的商品。这就是我对RxJava的理解,可能有点偏差但大致上和其思想比较接近。
其实关于RxJava的资料有很多,我主要是以学习分享为目的来说说自己学习RxJava所感所想,希望更和大家一起讨论学习进步。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/13359.html
摘要:让你收获满满码个蛋从年月日推送第篇文章一年过去了已累积推文近篇文章,本文为年度精选,共计篇,按照类别整理便于读者主题阅读。本篇文章是今年的最后一篇技术文章,为了让大家在家也能好好学习,特此花了几个小时整理了这些文章。 showImg(https://segmentfault.com/img/remote/1460000013241596); 让你收获满满! 码个蛋从2017年02月20...
摘要:框架基于的一款新闻阅读掘金,一款新闻阅读框架,基于,基本涵盖了当前端开发最常用的主流框架,基于此框架可以快速开发一个。本文已授权任阅小说阅读器,高仿追书神器掘金任阅小说阅读器。掘金清风音乐,一款安卓音乐播放器,基于。 AndroidFire框架--基于 Material Design+MVP+RxJava+Retrofit+Glide的一款新闻阅读 App - 掘金AndroidFir...
摘要:关于是推出在环境下使用的异步操作库。被观察者使用需要创建,用于发射数据。发射,可以表示发射事件结束。控制的线程,也可以说是控制事件被执行时所在的线程。输出结果操作符表示跳过前几个事件从某一个事件开始发射事件,下标从开始。 关于RxJava RxJava是ReactiveX推出在Java VM环境下使用的异步操作库。除了在Java环境ReactiveX也为其他编程语言推出Rx库,例如Py...
摘要:来总结一下我遇到的坑,或者说我为什么不在推荐使用。但是功利的看,在解决异步处理这个问题上,的确是投入高,收获少。这种在轻量级应用,或者一些小型异步处理比如数据埋点等等行为中,都显得过于庞大。距离上一次更新也有一段时间了,其实这篇文章我早就想写,碍于一直没来得及总结(懒)。所以一直没有成文。来总结一下我RxJava遇到的坑,或者说我为什么不在推荐使用RxJava。 相信熟悉或者关注我的朋友,绝...
摘要:动态代理个经纪人如何代理个明星掘金在代理模式女朋友这么漂亮,你缺经纪人吗中我们用宝强的例子介绍了静态代理模式的概念。掘金使用从头创建一个,这种方法比较简单。 动态代理:1 个经纪人如何代理 N 个明星 - Android - 掘金在 代理模式:女朋友这么漂亮,你缺经纪人吗? 中我们用宝强的例子介绍了静态代理模式的概念。 本来我的目的是通过大家耳熟能详的例子来加深理解,但是有些网友指责...
阅读 1518·2021-11-24 09:39
阅读 2867·2021-11-17 09:33
阅读 1357·2021-11-16 11:54
阅读 3184·2021-11-11 16:55
阅读 1241·2021-10-14 09:43
阅读 1219·2019-08-30 15:55
阅读 1067·2019-08-30 15:54
阅读 3290·2019-08-30 15:53