RxJava intro

关于流式编程的一些说明，Stream API

// JavaScript
let r = [1,2,3,4,5,6,7,8,9].filter(i=>i>5).map(i=>i*10).reduce((a,b)=>a+b, 0)

// Ruby
r = [1,2,3,4,5,6,7,8,9].select {|i| i>5}.map {|i| i*10}.reduce(0) {|a,b| a+b}

// Swift
var r = [1,2,3,4,5,6,7,8,9].filter {$0>5}.map {$0*10}.reduce(0) {$0+$1}

Integer[] numbers = new Integer[]{1, 2, 3, 4, 5, 6, 7, 8, 9};
Observable.from(numbers)
        .filter(integer) -> { return integer > 5; })
        .map((integer) -> { return integer * 10; })
        .reduce(0, (int1, int2) -> { return int1 + int2; })
        .subscribe((integer) -> { Log.i(TAG, "result: " + integer); });

流式编程法，每一个单独的步骤，在内部都重新对整体数据进行一次循环，因此它要做很多次小循环，但整体的流程只走一遍。
Rx，只在数据最源头，对整体数据进行一次循环，取出每一个单独的数据，让它去走一遍整体流程，因此，它只做一次循环，但整个的流程会走很多遍。

对于 Rx 来说，如果数据源不是固定的，那么它可以监听这个数据来源，当有数据到来时，它就可以把它发射出去把整个流程走一遍。这就是我用来理解 Rx 的观察者模式和响应式编程的方法。

Rx 比常见流式编程的抽象程度更高，它不光抽象了对数据的操作，还抽象了线程切换操作。

Rx的Promise和Observable对象：

Promise 对象，当它被 new 出来后，其中的方法体是立即执行的，不管后面有没有用 .then() 加上回调，执行的结果被存储在对象之中，如果后面再用 .then() 加上回调，之前的结果会马上传递给新的回调。
Rx 的 Observable 对象，当它被 new 出来后，其中的方法体，只有 .subscribe() 方法被执行的那一刻才会执行，否则，只要没有调用 .subscribe()，其中的变换就永远不会执行，这和 Promise 是完全不一样的。

只要是 T -> Observable 的变换，就应该用 flatMap