RxJava 数学运算符|极客教程

RxJava 数学运算符

以下是对由Observable发出的所有项进行操作的运算符。

序号	运算符和描述
1	Average 计算所有项的平均值并输出。
2	Concat 在不交替的情况下输出多个可观察对象的所有项。
3	Count 计算所有项的数量并输出。
4	Max 计算所有项中的最大值并输出。
5	Min 计算所有项中的最小值并输出。
6	Reduce 对每个项应用一个函数并返回结果。
7	Sum 计算所有项的总和并输出。

数学运算符示例

在任何您选择的编辑器中创建以下Java程序，比如在C:> RxJava中。

ObservableTester.java

import io.reactivex.Observable;
//Using concat operator to operate on multiple Observables
public class ObservableTester  {
   public static void main(String[] args)  throws InterruptedException {    
      Integer[] numbers = { 1, 2, 3, 4, 5, 6};
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable1 = Observable.fromArray(letters);
      Observable<Integer> observable2 = Observable.fromArray(numbers);
      Observable.concat(observable1, observable2)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}