前言#
上一篇已经把一些基础的api都介绍了，这次再多聊一些api以及如何进行线程切换。
正文#
首先我们来聊一聊线程切换的问题，例如最近非常流行的RxAndroid + Retrofit + OkHttp，典型的框架之间的结合使用，那么问题来了，Android是不允许在主线程发起的，没有线程切换那就肯定要蛋疼了，例如下面的伪代码：
Observable<String>
// 这些都在新线程里
.map("对url进行一些处理，例如一些公共参数的拼接等等")
.flatMap("通过发起网络请求，把String转换成我们想要的bean")
.map("对bean进行判断，例如请求码之类的")
// 回调在主线程中
.subscribe("回调监听");
我们希望指定某些代码是在特定的线程去执行，所以这个时候就需要使用 subscribeOn()，observeOn() ，从命名我们大概看的出来，subscribeOn估计就是设置回调的线程，observeOn应该是指定观察的线程，也就是除了subscribe以外的代码。
observeOn() 指定的是它之后的操作所在的线程，这对于逻辑也很有帮助，对之后的代码有效，并且可以调用多次。
subscribeOn（）理论上是应该只调用一次的，他只对subscribe有作用，并且只有第一次有效，具体为什么大家可以自己去查一查资料，了解一下内部的原理。
ok，最后再看看可以指定哪些线程：
Schedulers.io() : io线程池，例如文件读写之类的操作
Schedulers.computation() ：执行计算相关的操作
Schedulers.newThread()：新线程
AndroidSchedulers.mainThread() ：Android主线程，也就是UI线程。
上面就是我们常用的线程，当前还有其他的，不过用的很少就不提了。这样我们就可以对上面的伪代码进行修改：
Observable<String>
// 这些都在新线程里
.observeOn(Schedulers.newThread())
.map("对url进行一些处理，例如一些公共参数的拼接等等")
.flatMap("通过发起网络请求，把String转换成我们想要的bean")
.map("对bean进行判断，例如请求码之类的")
// 回调在主线程中
.subscribeOn(AndroidSchedulers.mainThread())
.subscribe("回调监听");
是不是非常的简单，所以就省去了我们大量的Handler.post()或者是RunOnUIThread（）代码和忽然发现没有Context的尴尬情况。
<h2>其他的一些api</h2>
最后再聊聊一些其他的api，工作里面也可能会用到：
reduce : 减少被观察者的对象数量。
reduce(new BiFunction<School, School, School>() {
@Override
public School apply(@NonNull School school, @NonNull School school2) throws Exception {
return null;
}
});
有时候我们通过flatMap增加了很多的被观察者，同样我们还可以减少被观察者，从参数就看的出来，看一个小demo：
private class School {
public String[] student = {"111", "222", "222", "222", "222", "222", "222", "222", "222", "222", "222"};
}
Observable.just(new School())
.flatMap(new Function<School, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(@NonNull School school) throws Exception {
return Observable.fromArray(school.student);
}
})
.reduce(new BiFunction<String, String, String>() {
@Override
public String apply(@NonNull String s1, @NonNull String s2) throws Exception {
return s1 + s2;
}
})
.subscribe(new MaybeObserver<String>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
}
@Override
public void onSuccess(@NonNull String s) {
Log.e("lzp", s);
}
@Override
public void onError(@NonNull Throwable e) {
}
@Override
public void onComplete() {
}
});
非常简单的代码，我把School对象通过flatMap映射出多个字符串对象，然后我再reduce，把字符串拼合起来，那么我得到的结果是什么呢？
06-20 17:46:47.747 26423-26423/com.lzp.rxjavastudy E/lzp: 111222222222222222222222222222222
最后得到了一个由数组里所有的字符串拼成的大字符串。
compose：英文是组成的意思，他最大的特点就是用在封装上，例如可以把相同的封装起来，像之前提到的公共参数，直接封装成Obsever然后就拼接到想要的Obsever中就可以了。
Observable.just(new School()).flatMap(new Function<School, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(@NonNull School school) throws Exception {
return Observable.fromArray(school.student);
}
}).compose(new ObservableTransformer<String, String>() {
@Override
public ObservableSource<String> apply(@NonNull Observable<String> upstream) {
return upstream.map(new Function<String, String>() {
@Override
public String apply(@NonNull String s) throws Exception {
return s + "hahaha";
}
});
}
})...
上面的代码增加compose，对所有的String都拼接了hahaha，看一下结果:
06-20 18:04:21.353 15429-15429/? E/lzp: 111hahaha222hahaha222hahaha222hahaha222hahaha222hahaha222hahaha222hahaha222hahaha222hahaha222hahaha
distinct() : 去除重复对象。
有时候我们列表里可能会有相同的对象，例如我的字符串数组中有好多的 111 ，222，如果我只想保留一个，我就可以直接调用distinct():
Observable.just(new School()).flatMap(new Function<School, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(@NonNull School school) throws Exception {
return Observable.fromArray(school.student);
}
}).distinct().compose...
在compose之前加上distinct（）方法，看一些结果：
06-20 18:08:43.618 21419-21419/com.lzp.rxjavastudy E/lzp: 111hahaha222hahaha
跟我预想的完全一样。
总结#
我也是刚接触RxJava没多久，写的东西都是非常基础的使用场景，还有很多很多的api都还没有使用过，但是RxJava的特性确实让人眼前一亮，让开发者省去了大量的精力去思考如何更新UI等等蛋疼的问题，如果再有更深的体会，再写一写新的东西出来跟大家分享。
