RxJava - объединение операторов

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

Sr.No.	Оператор и описание
1	And/Then/When Комбинируйте наборы предметов, используя посредников Pattern и Plan.
2	CombineLatest Объедините последний элемент, созданный каждым Observable через указанную функцию, и испустите полученный элемент.
3	Join Объедините элементы, испускаемые двумя наблюдаемыми объектами, если они испускаются в течение периода времени второго отправленного объекта Observable.
4	Merge Объединяет элементы, излучаемые Observables.
5	StartWith Выпустить указанную последовательность элементов перед тем, как начать выпускать элементы из источника Observable
6	Switch Испускает самые последние элементы, созданные Observables.
7	Zip Объединяет элементы Observables на основе функции и генерирует полученные элементы.

Пример оператора комбинирования

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

ObservableTester.java

import io.reactivex.Observable;
//Using combineLatest operator to combine Observables
public class ObservableTester {
   public static void main(String[] args) {    
      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.combineLatest(observable1, observable2, (a,b) -> a + b)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}