RxJava — математические операторы

Ниже приводятся операторы, которые оперируют целыми объектами, испускаемыми Observable.

Средний

Оценивает средние значения всех элементов и выдает результат.

Concat

Выдает все предметы из нескольких наблюдаемых без чередования.

подсчитывать

Подсчитывает все предметы и испускает результат.

Максимум

Оценивает максимально ценный предмет из всех предметов и выдает результат.

Min

Оценивает минимальный предмет из всех предметов и выдает результат.

уменьшить

Примените функцию к каждому элементу и верните результат.

сумма

Оценивает сумму всех предметов и выдает результат.

Пример математического оператора

Создайте следующую 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

Он должен произвести следующий вывод —