RxJava - 变换操作符

以下是用于变换可观察对象发出的项目的运算符。

序号	操作符及描述
1	Buffer 定期将可观察对象中的项目收集到捆绑包中，然后发出这些捆绑包而不是项目本身。
2	FlatMap 用于嵌套的可观察对象。将项目转换为可观察对象。然后将项目展平为单个可观察对象。
3	GroupBy 将可观察对象划分为按键组织的可观察对象集合，以发出不同组的项目。
4	Map 对每个发出的项目应用一个函数来对其进行转换。
5	Scan 依次对每个发出的项目应用一个函数，然后发出连续的值。
6	Window 定期将可观察对象中的项目收集到可观察对象的窗口中，然后发出这些窗口而不是项目本身。

变换操作符示例

使用您选择的任何编辑器（例如，在 C:\> RxJava 中）创建以下 Java 程序。

ObservableTester.java

import io.reactivex.Observable;
//Using map operator to transform an Observable
public class ObservableTester  { 
   public static void main(String[] args) {    
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable = Observable.fromArray(letters);
      observable
         .map(String::toUpperCase)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}

验证结果

使用 **javac** 编译器编译该类，如下所示：

C:\RxJava>javac ObservableTester.java

现在运行 ObservableTester，如下所示：

C:\RxJava>java ObservableTester

它应该产生以下输出：

ABCDEFG

打印页面