前言
Hello，小伙伴们大家好啊！上周给大家写了一个retrofit+rxjava的使用，有些小伙伴就说了，rxjava什么鬼哦，不会用啊...好吧，那么今天给大家带来一些我自己平时开发中常用的一些操作符，以便大家更快上手rxjava。
RxJava简介
相信大家就算没有用过RxJava也听说过，作为一个响应式编程框架，RxJava写出来的代码确实很优雅，链式编程嘛，简洁。相信大家刚接触RxJava的时候，听到最多的就是Observables是一个被观察者，Subscribers是一个观察者，用Observables（被观察者）订阅Subscribers（观察者）诸如此类的话，然后就蒙蔽了。。。内心一万个草泥马奔腾而过。其实大家没必要被概念搞混淆了，我的理解是你只需要知道我用Observable发出指令，Subscriber要执行就会理解好多。
//创建一个Observable
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
//发出一个事件
e.onNext("lxt");
}
}).subscribeOn(Schedulers.io())//在io线程执行事件
.observeOn(AndroidSchedulers.mainThread())//转换到主线程
.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
//接收到发出的事件，做自己的操作
Log.d("MainActivity", s);
}
});
那么这就是一个最基本的RxJava使用，接下来给大家说说常用的操作符。
操作符介绍
creat()
相信大家看到上面的代码也能猜到，没错，creat()就是创建一个Observable，然后你就可以开始为所欲为了。
just()
可以接收一系列参数，然后依次发射出来，比如
//创建一个Observable
Observable.just(1, 2, 3)
.map(new Function<Integer, String>() {
@Override
public String apply(@NonNull Integer integer) throws Exception {
//接收到事件，转换为String类型并返回
return String.valueOf(integer);
}
})
.subscribeOn(Schedulers.io())//在io线程执行事件
.observeOn(AndroidSchedulers.mainThread())//转换到主线程
.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
//接收到发出的事件，做自己的操作
Log.d("MainActivity", s);
}
});
运行结果如下：
1
2
3
map()
map操作符可以说是开发中用到最多的一个操作符，至少对于我来说是，map()的作用就是转换，比如你有一个Integer类型的，现在需要输出String类型，那么就可以用到map，上代码。
//创建一个Observable
Observable.create(new ObservableOnSubscribe<Integer>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Integer> e) throws Exception {
//发出一个Integer类型的事件
e.onNext(250);
}
})
.map(new Function<Integer, String>() {
@Override
public String apply(@NonNull Integer integer) throws Exception {
//接收到事件，转换为String类型并返回
return String.valueOf(integer);
}
})
.subscribeOn(Schedulers.io())//在io线程执行事件
.observeOn(AndroidSchedulers.mainThread())//转换到主线程
.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
//接收到发出的事件，做自己的操作
Log.d("MainActivity", s);
}
});
flatmap()
Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable。
//创建一个Observable
Observable.just(0)
.flatMap(new Function<Integer, ObservableSource<Integer>>() {
@Override
public ObservableSource<Integer> apply(@NonNull Integer integer) throws Exception {
//注意，这里返回的依然是一个Observable,可以重新发射事件或者做其他的操作
return Observable.just(integer + 5);
}
})
.map(new Function<Integer, String>() {
@Override
public String apply(@NonNull Integer integer) throws Exception {
return String.valueOf(integer);
}
})
.subscribeOn(Schedulers.io())//在io线程执行事件
.observeOn(AndroidSchedulers.mainThread())//转换到主线程
.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
//接收到发出的事件，做自己的操作
Log.d("MainActivity", s);
}
});
运行结果如下：
5
flatMap()是不是看起来很奇怪？为什么它要返回另外一个Observable呢？理解flatMap的关键点在于，flatMap输出的新的 Observable正是我们在Subscriber想要接收的。
interval()
定时器，每隔多久执行一次任务，这里给大家截个图，看一下参数列表
initialDelay就是延时多久开始，period就是每隔多久执行一次,unit就是时间类型，毫秒，秒还是小时等等，里面封装了常量。你可以选择延时多久后开始循环执行，也可以不延迟马上开始循环执行任务
//延时1秒之后，每过1秒执行一次任务
Observable.interval(1, 1, TimeUnit.SECONDS)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Long>() {
@Override
public void accept(@NonNull Long aLong) throws Exception{
//do something...
}
});
filter()
过滤操作符，得到你想要得到的数据，比如
Observable.just(1, 2, 3, 4)
.filter(new Predicate<Integer>() {
@Override
public boolean test(@NonNull Integer integer) throws Exception {
//只拿偶数
return integer % 2 == 0;
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Integer>() {
@Override
public void accept(@NonNull Integer integer) throws Exception {
Log.d("MainActivity", "integer:" + integer);
}
});
输出结果:
2
4
总结
当然RxJava操作符远不止这些，上面的一些操作符基本就是本人开发中经常用到的，算是给自己做一个总结吧，愿不会使用RxJava的小伙伴早日用上RxJava，最后祝大家工作顺心。
