RxJava - математические операторы
Ниже приведены операторы, которые работают со всеми элементами, создаваемыми Observable.
Sr.No. | Оператор и описание |
---|---|
1 | Average Оценивает средние значения по всем элементам и выдает результат. |
2 | Concat Испускает все элементы из нескольких наблюдаемых без чередования. |
3 | Count Подсчитывает все элементы и выдаёт результат. |
4 | Max Оценивает максимально оцененный элемент всех элементов и выдает результат. |
5 | Min Оценивает минимальную ценность всех элементов и выдаёт результат. |
6 | Reduce Примените функцию к каждому элементу и верните результат. |
7 | Sum Оценивает сумму всех элементов и выдаёт результат. |
Пример математического оператора
Создайте следующую программу Java, используя любой редактор по вашему выбору, например, 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);
}
}
Проверить результат
Скомпилируйте класс, используя javac компилятор следующим образом -
C:\RxJava>javac ObservableTester.java
Теперь запустите ObservableTester следующим образом -
C:\RxJava>java ObservableTester
Он должен выдать следующий результат -
abcdefg123456