RxJava - Koşullu Operatörler

Aşağıda, bir veya daha fazla Gözlemlenebilir Öğeyi veya yayılan öğeyi değerlendiren operatörler yer almaktadır.

Sr.No.	Operatör ve Açıklama
1	All Verilen kriterleri karşılamak için yayılan tüm öğeleri değerlendirir.
2	Amb Yalnızca birden fazla Gözlemlenebilir Veriyle birlikte ilk Gözlemlenebilirden tüm öğeleri yayar.
3	Contains Bir Gözlemlenebilir Öğenin belirli bir öğeyi yayıp yaymadığını kontrol eder.
4	DefaultIfEmpty Gözlemlenebilir herhangi bir şey yaymazsa varsayılan öğeyi yayar.
5	SequenceEqual İki Gözlemlenebilir Öğenin aynı öğe sırasını yayıp yaymadığını kontrol eder.
6	SkipUntil İlk Gözlemlenebilir tarafından yayılan öğeleri, ikinci bir Gözlemlenebilir öğe bir öğe yayana kadar atar.
7	SkipWhile Belirli bir koşul yanlış hale gelene kadar bir Gözlemlenebilirlik tarafından yayılan öğeleri atın.
8	TakeUntil İkinci bir Gözlemlenebilir Öğeyi yayınladıktan veya sona erdikten sonra bir Gözlemlenebilirlik tarafından yayılan öğeleri atar.
9	TakeWhile Belirli bir koşul yanlış hale geldikten sonra bir Gözlemlenebilirlik tarafından yayılan öğeleri atın.

Koşullu Operatör Örneği

C: \> RxJava'da seçtiğiniz herhangi bir düzenleyiciyi kullanarak aşağıdaki Java programını oluşturun.

ObservableTester.java

import io.reactivex.Observable;
//Using defaultIfEmpty operator to operate on an Observable
public class ObservableTester  {
   public static void main(String[] args) {    
      final StringBuilder result = new StringBuilder();
      Observable.empty()
      .defaultIfEmpty("No Data")
      .subscribe(s -> result.append(s));
      System.out.println(result);
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result1 = new StringBuilder();
      Observable.fromArray(letters)
      .firstElement()
      .defaultIfEmpty("No data")   
      .subscribe(s -> result1.append(s));
      System.out.println(result1);
   }
}