RxJava - Filtreleme Operatörleri

Aşağıdakiler, bir Gözlemlenebilir Öğeden seçici olarak öğe (leri) yaymak için kullanılan operatörlerdir.

Sr.No.	Operatör ve Açıklama
1	Debounce Öğeleri yalnızca, başka bir öğe yaymadan zaman aşımı oluştuğunda yayar.
2	Distinct Yalnızca benzersiz öğeleri yayar.
3	ElementAt Yalnızca bir Observable tarafından yayılan n dizindeki öğeyi yayar.
4	Filter Yalnızca verilen yüklem işlevini geçen öğeleri yayar.
5	First Verilen ölçütü geçen ilk öğeyi veya ilk öğeyi yayar.
6	IgnoreElements Observable'dan herhangi bir öğe yaymayın, ancak tamamlandığını gösterir.
7	Last Observable'dan son öğeyi yayar.
8	Sample Belirli bir zaman aralığına sahip en son öğeyi yayınlar.
9	Skip Bir Gözlemlenebilirden ilk n öğeyi atlar.
10	SkipLast Bir Gözlemlenebilirden son n öğeyi atlar.
11	Take Bir Gözlemlenebilirden ilk n maddeyi alır.
12	TakeLast bir Gözlemlenebilirden son n maddeyi alır.

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