Rxjava 简明教程
RxJava - Creating Operators
以下是用于创建可观察内容的操作符。
Sr.No. |
Operator & Description |
1 |
Create 从头开始创建可观察内容，并允许观察者方法以编程方式调用。 |
2 |
Defer 在观察者订阅之前不要创建一个 Observable。为每个观察者创建新的 observable。 |
3 |
Empty/Never/Throw 创建一个行为受限的 Observable。 |
4 |
From 将对象/数据结构转换成 Observable。 |
5 |
Interval 创建一个 Observable 按照指定的时间间隔顺序发出整数值。 |
6 |
Just 将一个对象/数据结构转换成 Observable 以发出相同或相同类型的对象。 |
7 |
Range 创建一个 Observable 按照给定范围顺序发出整数值。 |
8 |
Repeat 创建一个 Observable 顺序重复发出整数值。 |
9 |
Start 创建一个 Observable 以发出一个函数的返回值。 |
10 |
Timer 创建一个 Observable 以在指定延迟后发出一个单一项目。 |
Creating Operator Example
在任意编辑器中使用任何您选择的语言（如 C:\>RxJava) 创建以下 Java 程序。
ObservableTester.java
import io.reactivex.Observable;
//Using fromArray operator to create 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);
}
}