RxJava 转换操作符
RxJava 转换操作符 介绍
以下是用于转换从 Observable 发出的信息的运算符。
| 运算符 | 描述 |
|---|---|
| Buffer | 定期将 Observable 中的项目收集到包中，然后发出包而不是项目。 |
| FlatMap | 用于嵌套的 observable。将项目转换为 Observable。然后将项目展平为单个 Observable。 |
| GroupBy | 将一个 Observable 分成按键组织的一组 Observable 以发出不同的项目组。 |
| Map | 将函数应用于每个发出的项目以对其进行转换。 |
| Scan | 对每个发出的项目依次应用一个函数，然后发出连续的值。 |
| Window | 定期将 Observable 中的项目收集到 Observable 窗口中，然后发送窗口而不是项目。 |
RxJava 转换操作符 示例
package cn.xnip;
import io.reactivex.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);
}
}
输出结果为：
