RxJava - Opérateurs mathématiques

Voici les opérateurs qui opèrent sur des éléments entiers émis par un observable.

N ° Sr.	Opérateur et description
1	Average Évalue les moyennes de tous les éléments et émet le résultat.
2	Concat Émet tous les éléments de plusieurs observables sans entrelacement.
3	Count Compte tous les éléments et émet le résultat.
4	Max Évalue l'élément valorisé maximum de tous les éléments et émet le résultat.
5	Min Évalue l'élément de valeur minimale de tous les éléments et émet le résultat.
6	Reduce Appliquez une fonction sur chaque élément et renvoyez le résultat.
sept	Sum Évalue la somme de tous les éléments et émet le résultat.

Exemple d'opérateur mathématique

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 concat operator to operate on multiple Observables
public class ObservableTester  {
   public static void main(String[] args)  throws InterruptedException {    
      Integer[] numbers = { 1, 2, 3, 4, 5, 6};
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable1 = Observable.fromArray(letters);
      Observable<Integer> observable2 = Observable.fromArray(numbers);
      Observable.concat(observable1, observable2)
         .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 -

abcdefg123456