RxJava教程
 RxJava 合并运算符 RxJava 条件运算符 

RxJava 工具运算符

RxJava 工具运算符 介绍

以下是通常对 Observable 工具运算符。

运算符 描述
Delay 注册操作以处理 Observable 生命周期事件。
Materialize/Dematerialize 表示发出的项目和发送的通知。
ObserveOn 指定要观察的调度程序。
Serialize 强制 Observable 进行序列化调用。
Subscribe 操作来自 Observable 的项目和通知的发送
SubscribeOn 指定 Observable 在订阅时要使用的调度程序。
TimeInterval 将 Observable 转换为发射之间经过的时间量的指示。
Timeout 如果发生指定时间而没有发出任何项目，则发出错误通知。
Timestamp 将时间戳附加到发出的每个项目。
Using 创建一个一次性资源或与 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.subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}

输出结果为：

 RxJava 合并运算符 RxJava 条件运算符 

热门文章

优秀文章

全部教程