RxJava - Operator Penyaring

Berikut adalah operator yang digunakan untuk secara selektif mengeluarkan item dari Observable.

Sr.No.	Operator & Deskripsi
1	Debounce Memancarkan item hanya saat batas waktu terjadi tanpa mengeluarkan item lain.
2	Distinct Hanya mengeluarkan item unik.
3	ElementAt memancarkan hanya item pada indeks n yang dipancarkan oleh Observable.
4	Filter Hanya mengeluarkan item yang lulus fungsi predikat yang diberikan.
5	First Mengeluarkan item pertama atau item pertama yang lolos kriteria yang ditentukan.
6	IgnoreElements Jangan memancarkan item apa pun dari Observable tetapi menandai selesai.
7	Last Memancarkan elemen terakhir dari Observable.
8	Sample Memancarkan item terbaru dengan interval waktu tertentu.
9	Skip Lewati n item pertama dari Observable.
10	SkipLast Lewati n item terakhir dari Observable.
11	Take mengambil n item pertama dari Observable.
12	TakeLast mengambil n item terakhir dari Observable.

Contoh Operator Filter

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

ObservableTester.java

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