RxJava — Создание операторов

Ниже приведены операторы, которые используются для создания Observable.

Создайте

Создает Observable с нуля и позволяет методу наблюдателя вызываться программно.

Перенести

Не создавайте Observable, пока наблюдатель не подпишется. Создает свежую наблюдаемую для каждого наблюдателя.

Пустой / Никогда / Throw

Создает Observable с ограниченным поведением.

От

Преобразует объект / структуру данных в Observable.

интервал

Создает наблюдаемые исходящие целые числа в последовательности с промежутком заданного временного интервала.

Просто

Преобразует структуру объекта / данных в Observable для излучения объектов того же или того же типа.

Спектр

Создает наблюдаемые исходящие целые числа в последовательности заданного диапазона.

Повторение

Создает наблюдаемые исходящие целые числа последовательно.

Начните

Создает Observable для выдачи возвращаемого значения функции.

таймер

Создает Observable для испускания одного предмета после заданной задержки.

Пример создания оператора

Создайте следующую Java-программу, используя любой редактор по вашему выбору, например, в C: \> RxJava.

ObservableTester.java

import io.reactivex.Observable;
//Using fromArray operator to create 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
         .map(String::toUpperCase)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}

Проверьте результат

Скомпилируйте класс с помощью компилятора javac следующим образом:

C:\RxJava>javac ObservableTester.java

Теперь запустите ObservableTester следующим образом:

C:\RxJava>java ObservableTester

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