RxJava教程
 RxJava CompositeDisposable类 RxJava 转换操作符 

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);
   }
}

输出结果为：

 RxJava CompositeDisposable类 RxJava 转换操作符 

热门文章

优秀文章

全部教程