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