RxJava 转换操作符
精华
小牛编辑
109浏览
2023-03-14
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);
}
}
输出结果为: