在第一部分，我介绍了RxJava的基本结构；在第二部分我讲述了RxJava强大的操作符。但也许你还是没有被说服，这里将介绍RxJava框架的其他优点，它们应该能够说服你。
错误处理
一直到现在，我们都忽略了onComplete()和onError()，它们标记着一个Observable停止发送数据的时间和原因（不论是成功完成还是不可恢复的错误）。
我们初始的Subscriber有监听onComplete()和onError()的能力。让我们用这两个方法来做点实际的事吧：
Observable.just("Hello, world!")
.map(s -> potentialException(s))
.map(s -> anotherPotentialException(s))
.subscribe(new Subscriber<String>() {
@Override
public void onNext(String s) { System.out.println(s); }
@Override
public void onCompleted() { System.out.println("Completed!"); }
@Override
public void onError(Throwable e) { System.out.println("Ouch!"); }
});
我们说potentialException()和anotherPotentialException()都有抛出异常的可能，每个Observable都以调用一次onComplete()或者onError()结束。就这样，程序的输出要么是一个String后接“Completed!”，要么就是“Ouch!”（因为有异常抛出）。
从这个模式中我们可以得出几个结论：
1. 任何时候，如果有异常被抛出，onError()就会被调用。
这使得错误处理变得极为简单，我能够只在一个方法的最后处理每个错误。
2. 操作符并不一定要处理错误。
你能够一直到Subscriber中才决定怎么处理Observable链中任意一部分的错误，因为异常会跳到onError()。
3. 你可以知道Subscriber结束接收数据的时间。
知道一个任务的结束时间可以帮助你整理代码流（尽管有可能一个Observable永远不会执行结束）。
我发现这个模式比传统的错误处理要简便得多。采用回调，你必须在每一个回调中都进行错误处理，这不仅会导致繁复的代码，而且意味着每一个回调都必须知道如何处理错误，也意味着你的回调和它的调用者是紧耦合的。
然而采用RxJava的这种模式，你的Observable甚至不需要知道如何处理错误。所有的操作符也不需要处理错误状态——在发送关键错误的情况下它会被跳过。你可以将你所有的错误处理都放到Subscriber中。
调度器
假设你有一个Android APP需要进行网络请求，这可能会耗费很长时间，所以你需要新开线程来处理它，突然，这就遇到了问题。
多线程的Android应用是很麻烦的，因为你必须保证你的代码运行在正确的线程中，如果错了，你的应用就会crash。典型的异常发生在非主线程中修改View的状态。
使用RxJava，你可以使用subscribeOn()指定你的Observer代码运行的线程，也可以使用observeOn()指定你的Subscriber运行在哪个线程：
myObservableServices.retrieveImage(url)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap));
很简单吧？Subscriber之前的所有代码都运行在IO线程中，最后，我的View操作发生在主线程。
这里的卓越之处在于我能给任意的Observable添加subscribeOn()和observeOn()。它们只是操作符！我不需要担心Observable或者之前的操作符正在做什么；我只需要在最后加上这些就可以方便地进行多线程编程。
Subscriptions
其实我还有一些事情隐瞒了你。当你调用Observable.subscribe()的时候，返回的是一个Subscription。它代表着你的Observable和你的Subscriber之间的联系：
Subscription subscription = Observable.just("Hello, World!")
.subscribe(s -> System.out.println(s));
你随后也可以使用Subscription来切断这种联系：
subscription.unsubscribe();
System.out.println("Unsubscribed=" + subscription.isUnsubscribed());
// Outputs "Unsubscribed=true"
RxJava取消订阅的好处是它切断了整个链式调用。如果你有一个复杂的操作链，使用unsubscribe()你可以在代码运行到的任何地方终止，却不需要任何其他工作。
结论
记住，这个系列文章只是RxJava的一个简介，除了我说的这些外还有太多值得去学，并且不会是一帆风顺的（比如，读读这篇文章）。我也不是所有的代码都使用Reactive的——我将它留到我想要简化逻辑的程序的复杂部分。
一开始，我是计划将这篇文章作为这个系列的结束的，后来很多人要求给出一个在Android上使用RxJava的练习demo，所以你现在可以继续阅读第四部分（需要科学上网）。我希望这个介绍足以让你开始动手编程了，如果你想了解更多的话，我建议你阅读RxJava官方wiki，并且记住，一切皆有可能。
