RxJava - Operadores de transformação

A seguir estão os operadores que são usados para transformar um item emitido de um Observable.

Sr. Não.	Operador e descrição
1	Buffer Reúne itens do Observável em pacotes periodicamente e, em seguida, emite os pacotes em vez de itens.
2	FlatMap Usado em observáveis aninhados. Transforma itens em observáveis. Em seguida, achatar os itens em um único Observável.
3	GroupBy Divida um Observável em um conjunto de Observáveis organizado por chave para emitir diferentes grupos de itens.
4	Map Aplique uma função a cada item emitido para transformá-lo.
5	Scan Aplique uma função a cada item emitido, sequencialmente e, a seguir, emita o valor sucessivo.
6	Window Reúne itens de janelas Observáveis em janelas Observáveis periodicamente e, a seguir, emite as janelas em vez de itens.

Exemplo de operador de transformação

Crie o seguinte programa Java usando qualquer editor de sua escolha em, digamos, C: \> RxJava.

ObservableTester.java

import io.reactivex.Observable;
//Using map operator to transform 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);
   }
}