当前位置: 首页 > 教程 > RxJava >

RxJava 转换操作符

精华
小牛编辑
109浏览
2023-03-14

RxJava 转换操作符 介绍

以下是用于转换从 Observable 发出的信息的运算符。

运算符 描述
Buffer 定期将 Observable 中的项目收集到包中,然后发出包而不是项目。
FlatMap 用于嵌套的 observable。将项目转换为 Observable。然后将项目展平为单个 Observable。
GroupBy 将一个 Observable 分成按键组织的一组 Observable 以发出不同的项目组。
Map 将函数应用于每个发出的项目以对其进行转换。
Scan 对每个发出的项目依次应用一个函数,然后发出连续的值。
Window 定期将 Observable 中的项目收集到 Observable 窗口中,然后发送窗口而不是项目。

RxJava 转换操作符 示例

package cn.xnip;

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

输出结果为: