RxJava 为我们提供了两个调度操作符subscribeOn和observeOn. 它们分别可以在订阅(subscribe)阶段和观察(observe)阶段进行线程的调度。 示例代码

继续刚才KFC的例子。 我们都知道吮指原味鸡来自于鸡的不同部位，分别有鸡腿，鸡胸和鸡肋。 现在我这个人很挑，不吃鸡肋，该怎么办呢。 最直接的想法，我们当然可以很直接在KFC(Publisher)内做判断。 但是很快我们就发现了问题 想象一条流水线，KFC是起点，我是终点，我们不应该让KFC再也不生产鸡肋，而是应该在流水线上安排一个工人(KFC服务员)，由服务员来帮我们过滤鸡肋。KFC对服务员负责，服务员对我负责。

Reactive-streams 是 RxJava的唯一依赖，它是一项响应式编程API标准，已被java标准库收录。 Reactive-streams只定义了4个接口共计7个方法，这7个方法构成了整个Reactive世界。 由于这些方法都太直观了没什么好说的，我就举个例子: