RxJava - Transformer les opérateurs

Voici les opérateurs qui sont utilisés pour transformer un élément émis par un observable.

N ° Sr.	Opérateur et description
1	Buffer Rassemble périodiquement les éléments d'Observable dans des lots, puis émet les lots plutôt que les éléments.
2	FlatMap Utilisé dans les observables imbriqués. Transforme les éléments en observables. Ensuite, aplatissez les éléments en un seul observable.
3	GroupBy Divisez un observable en ensemble d'observables organisés par clé pour émettre différents groupes d'éléments.
4	Map Appliquez une fonction à chaque élément émis pour le transformer.
5	Scan Appliquez une fonction à chaque élément émis, séquentiellement puis émettez la valeur successive.
6	Window Rassemble périodiquement les éléments de Observable dans les fenêtres Observable, puis émet les fenêtres plutôt que les éléments.

Exemple d'opérateur de transformation

Créez le programme Java suivant en utilisant n'importe quel éditeur de votre choix dans, par exemple, 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);
   }
}

Vérifiez le résultat

Compilez la classe en utilisant javac compilateur comme suit -

C:\RxJava>javac ObservableTester.java

Exécutez maintenant l'ObservableTester comme suit -

C:\RxJava>java ObservableTester

Il devrait produire la sortie suivante -

ABCDEFG