RxJava - Operadores de transformación

A continuación se muestran los operadores que se utilizan para transformar un elemento emitido desde un Observable.

No Señor. Operador y descripción
1

Buffer

Reúne elementos de Observable en paquetes periódicamente y luego los emite en lugar de elementos.
2

FlatMap

Se utiliza en observables anidados. Transforma elementos en observables. Luego aplana los elementos en un solo Observable.
3

GroupBy

Divida un Observable en un conjunto de Observables organizados por clave para emitir diferentes grupos de elementos.
4

Map

Aplica una función a cada elemento emitido para transformarlo.
5

Scan

Aplicar una función a cada elemento emitido, secuencialmente y luego emitir el valor sucesivo.
6

Window

Reúne elementos de Observable en Observable windows periódicamente y luego emite las ventanas en lugar de elementos.

Ejemplo de operador transformador

Cree el siguiente programa Java utilizando cualquier editor de su elección en, 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);
   }
}

Verificar el resultado

Compila la clase usando javac compilador de la siguiente manera:

C:\RxJava>javac ObservableTester.java

Ahora ejecute ObservableTester de la siguiente manera:

C:\RxJava>java ObservableTester

Debería producir el siguiente resultado:

ABCDEFG