RxJava - Opérateurs de services publics

Voici les opérateurs qui sont souvent utiles avec Observables.

N ° Sr.	Opérateur et description
1	Delay Enregistrez l'action pour gérer les événements observables du cycle de vie.
2	Materialize/Dematerialize Représente l'élément émis et la notification envoyée.
3	ObserveOn Spécifiez le planificateur à observer.
4	Serialize Force Observable à effectuer des appels sérialisés.
5	Subscribe Opérer sur les émissions d'articles et de notifications comme complet à partir d'un observable
6	SubscribeOn Spécifiez le planificateur à utiliser par un observable lorsqu'il est abonné.
sept	TimeInterval Convertissez un observable pour émettre des indications sur le temps écoulé entre les émissions.
8	Timeout Emet une notification d'erreur si l'heure spécifiée se produit sans émettre aucun élément.
9	Timestamp Attachez l'horodatage à chaque élément émis.
9	Using Crée une ressource jetable ou la même durée de vie que celle d'Observable.

Exemple d'opérateur utilitaire

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 subscribe operator to subscribe to 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.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