RxJava 创建操作符|极客教程

RxJava 创建操作符

下面是用于创建Observable的操作符。

序号	操作符和描述
1	Create 从头开始创建Observable，并允许观察者方法以编程的方式调用。
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。

创建操作符示例

使用您选择的任何编辑器在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);
   }
}