RxJava - Operator Bersyarat

Berikut adalah operator yang mengevaluasi satu atau beberapa Observable atau item yang dipancarkan.

Sr.No.	Operator & Deskripsi
1	All Mengevaluasi semua item yang dipancarkan untuk memenuhi kriteria yang diberikan.
2	Amb Memancarkan semua item dari Observable pertama hanya dengan beberapa Observable.
3	Contains Memeriksa apakah Observable memancarkan item tertentu atau tidak.
4	DefaultIfEmpty Memancarkan item default jika Observable tidak memancarkan apa pun.
5	SequenceEqual Memeriksa apakah dua Observable memancarkan urutan item yang sama.
6	SkipUntil Buang item yang dipancarkan oleh Observable pertama sampai Observable kedua mengeluarkan item.
7	SkipWhile Buang item yang dipancarkan oleh Observable sampai kondisi tertentu menjadi salah.
8	TakeUntil Membuang item yang dipancarkan oleh Observable setelah Observable kedua memancarkan item atau berhenti.
9	TakeWhile Buang item yang dipancarkan oleh Observable setelah kondisi tertentu menjadi salah.

Contoh Operator Bersyarat

Buat program Java berikut menggunakan editor pilihan Anda di, misalnya, C: \> RxJava.

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);
   }
}