RxJava - Операторы утилит

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

Sr.No.	Оператор и описание
1	Delay Зарегистрируйте действие для обработки наблюдаемых событий жизненного цикла.
2	Materialize/Dematerialize Представляет отправленный элемент и отправленное уведомление.
3	ObserveOn Укажите планировщик, за которым нужно следить.
4	Serialize Заставить Observable выполнять сериализованные вызовы.
5	Subscribe Работайте с выбросами элементов и уведомлений, как завершено из наблюдаемого
6	SubscribeOn Укажите планировщик, который будет использоваться Observable при подписке.
7	TimeInterval Преобразуйте Observable, чтобы показывать количество времени, прошедшее между выбросами.
8	Timeout Выдает уведомление об ошибке, если указанное время происходит без выдачи какого-либо элемента.
9	Timestamp Прикрепите отметку времени к каждому отправляемому элементу.
9	Using Создает одноразовый ресурс или такой же срок службы, как у 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);
   }
}