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 com.yiidian;
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);
}
}
输出结果为:
热门文章
优秀文章