操作符

弹珠图查看每个指令的作用：https://rxmarbles.com/

map

跟stream一样

filter

跟stream一样

count

:::tips Observable的count跟stream不一样，它并不会中止流，而是返回一个只有一个新元素的响应式流，这个元素就是以上一个流的元素的个数 :::

zip

zip 操作符：通过指定的函数将多个 Observable 发送的元素组合在一起，并根据此函数的结果为每 个组合发出单个数据项

public static void main(String[] args) { 
    Observable.zip( Observable.just(1,2,3,4,5), 
                   Observable.just("a", "b", "c", "d", "e"), 
                   (a, b) -> a + b) 
        .forEach(System.out::println); 
}