上篇文章已经对RxJava的基础知识做了介绍。下面将介绍许多RxJava中的操作符。RxJava的强大性就来自它所定义的操作符。
首先看个例子：
有个方法，根据输入的字符串返回一个网站的url搜索列表
Observable<List<String>> query(String text);
query("Hello, world!")
.subscribe(urls -> {
for (String url : urls) {
System.out.println(url);
}
});
这种代码不能容忍，因为上面的代码urls是在subcriber中来替换的。可以使用Observable.from方法，它接收一个集合作为输入，然后每次输出一个元素给Subscriber
Observable.from("url1", "url2", "url3")
.subscribe(url -> System.out.println(url));
query("Hello, world!")
.subscribe(urls -> {
Observable.from(urls)
.subscribe(url -> System.out.println(url));
});
虽然去掉了foreach，但是有多个嵌套的Subscriber，不仅看起来很丑，难以下，更严重的是它会破坏某些我们现在还没有讲到的RxJava特性
改进
救星来了,他就是flatMap()。Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable。直接看代码：
query("Hello, world!")
.flatMap(new Func1<List<String>, Observable<String>>() {
@Override
public Observable<String> call(List<String> urls) {
return Observable.from(urls);
}
})
.subscribe(url -> System.out.println(url));
这里我贴出了整个的函数代码，以方便你了解发生了什么，使用lambda可以大大简化代码长度：
query("Hello, world!")
.flatMap(urls -> Observable.from(urls))
.subscribe(url -> System.out.println(url));
flatMap()是不是看起来很奇怪？为什么它要返回另外一个Observable呢？理解flatMap的关键点在于，flatMap输出的新的Observable正是我们在Subscriber想要接收的。现在Subscriber不再收到List<String>，而是收到一些列单个的字符串，就像Observable.from()的输出一样。
还可以更好
flatMap()实在不能更赞了，它可以返回任何它想返回的Observable对象。比如下面的方法：
// 返回网站的标题，如果404了就返回null
Observable<String> getTitle(String URL);
接着前面的例子，现在我不想打印URL了，而是要打印收到的每个网站的标题。问题来了，我的方法每次只能传入一个URL，并且返回值不是一个String，而是一个输出String的Observabl对象。使用flatMap()可以简单的解决这个问题。
query("Hello, world!")
.flatMap(urls -> Observable.from(urls))
.flatMap(new Func1<String, Observable<String>>() {
@Override
public Observable<String> call(String url) {
return getTitle(url);
}
})
.subscribe(title -> System.out.println(title));
使用lambda
query("Hello, world!")
.flatMap(urls -> Observable.from(urls))
.flatMap(url -> getTitle(url))
.subscribe(title -> System.out.println(title));
是不是感觉很不可思议？我竟然能将多个独立的返回Observable对象的方法组合在一起！帅呆了！不止这些，我还将两个API的调用组合到一个链式调用中了。我们可以将任意多个API调用链接起来。大家应该都应该知道同步所有的API调用，然后将所有API调用的回调结果组合成需要展示的数据是一件多么蛋疼的事情。这里我们成功的避免了callback hell（多层嵌套的回调，导致代码难以阅读维护）。现在所有的逻辑都包装成了这种简单的响应式调用。
丰富的操作符
目前为止，我们已经接触了两个操作符，RxJava中还有更多的操作符，那么我们如何使用其他的操作符来改进我们的代码呢？getTitle()返回null如果url不存在。我们不想输出"null"，那么我们可以从返回的title列表中过滤掉null值！
query("Hello, world!")
.flatMap(urls -> Observable.from(urls))
.flatMap(url -> getTitle(url))
.filter(title -> title != null)
.subscribe(title -> System.out.println(title));
filter()输出和输入相同的元素，并且会过滤掉那些不满足检查条件的。如果我们只想要最多5个结果：
query("Hello, world!")
.flatMap(urls -> Observable.from(urls))
.flatMap(url -> getTitle(url))
.filter(title -> title != null)
.take(5)
.subscribe(title -> System.out.println(title));
take()输出最多指定数量的结果。
如果我们想在打印之前，把每个标题保存到磁盘：
query("Hello, world!")
.flatMap(urls -> Observable.from(urls))
.flatMap(url -> getTitle(url))
.filter(title -> title != null)
.take(5)
.doOnNext(title -> saveTitle(title))
.subscribe(title -> System.out.println(title));
doOnNext()允许我们在每次输出一个元素之前做一些额外的事情，比如这里的保存标题。看到这里操作数据流是多么简单了么。你可以添加任意多的操作，并且不会搞乱你的代码。RxJava包含了大量的操作符。操作符的数量是有点吓人，但是很值得你去挨个看一下，这样你可以知道有哪些操作符可以使用。弄懂这些操作符可能会花一些时间，但是一旦弄懂了，你就完全掌握了RxJava的威力。
