RxJava - Création d'opérateurs

Voici les opérateurs qui sont utilisés pour créer un observable.

Sr.No.	Opérateur et description
1	Create Crée un Observable à partir de zéro et permet à la méthode d'observateur d'appeler par programme.
2	Defer Ne créez pas d'observable tant qu'un observateur n'est pas abonné. Crée une nouvelle observable pour chaque observateur.
3	Empty/Never/Throw Crée un observable avec un comportement limité.
4	From Convertit un objet / structure de données en observable.
5	Interval Crée un observable émettant des entiers en séquence avec un intervalle de temps spécifié.
6	Just Convertit un objet / structure de données en Observable pour émettre le même ou le même type d'objets.
sept	Range Crée un observable émettant des entiers dans l'ordre d'une plage donnée.
8	Repeat Crée un observable émettant des entiers en séquence à plusieurs reprises.
9	Start Crée un Observable pour émettre la valeur de retour d'une fonction.
dix	Timer Crée un observable pour émettre un seul élément après un délai donné.

Création d'un exemple d'opérateur

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 fromArray operator to create 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);
   }
}