RxJava - 转换运算符

以下是用于转换从 Observable 发出的项目的运算符。

先生。	运算符及描述
1	缓冲定期将 Observable 中的项目收集到包中，然后发出包而不是项目。
2	平面地图用于嵌套可观察量。将项目转换为可观察对象。然后将这些项目扁平化为单个 Observable。
3	通过...分组将一个 Observable 分成按键组织的一组 Observable，以发出不同的项目组。
4	地图对每个发出的项目应用一个函数来对其进行转换。
5	扫描按顺序将函数应用于每个发出的项目，然后发出连续的值。
6	窗户定期将 Observable 中的项目收集到 Observable 窗口中，然后发出窗口而不是项目。

转换运算符示例

使用您选择的任何编辑器（例如 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