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

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