RxJava 创建操作符
RxJava 创建操作符 介绍
以下是用于创建 Observable 的运算符。
| 运算符 | 描述 |
|---|---|
| Create | 从头开始创建一个 Observable 并允许以编程方式调用观察者方法。 |
| Defer | 在观察者订阅之前不要创建 Observable。为每个观察者创建一个新的 observable。 |
| Empty/Never/Throw | 创建一个行为受限的 Observable。 |
| From | 将对象/数据结构转换为 Observable。 |
| Interval | 创建一个 Observable 以指定的时间间隔按顺序发送整数。 |
| Just | 将对象/数据结构转换为 Observable 以发出相同或相同类型的对象。 |
| Range | 创建一个 Observable 按给定范围的序列发送整数。 |
| Repeat | 重复创建一个按顺序发送整数的 Observable。 |
| Start | 创建一个 Observable 以发出函数的返回值。 |
| Timer | 创建一个 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);
}
}
输出结果为：
