RxJava — Утилиты

Ниже приведены операторы, которые часто полезны с Observables.

задержка

Зарегистрируйте действие для обработки наблюдаемых событий жизненного цикла.

Материализовать / дематериализоваться

Представляет отправленный элемент и отправленное уведомление.

ObserveOn

Укажите планировщик для наблюдения.

Сериализация

Force Observable совершать сериализованные вызовы.

Подписывайся

Работать на выбросы предметов и уведомлений, как полный из наблюдаемой

SubscribeOn

Укажите планировщик, который будет использоваться Observable, когда он подписан.

Интервал времени

Преобразование Обсерватории в излучение с указанием количества времени, прошедшего между выбросами.

Тайм — аут

Выдает уведомление об ошибке, если указанное время происходит без отправки какого-либо элемента.

Отметка

Прикрепите метку времени к каждому излучаемому элементу.

С помощью

Создает одноразовый ресурс или тот же срок жизни, что и у Observable.

Пример утилиты оператора

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

ObservableTester.java

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

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

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

C:\RxJava>javac ObservableTester.java

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

C:\RxJava>java ObservableTester

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