RxJava - Opérateurs de filtrage

Voici les opérateurs qui sont utilisés pour émettre sélectivement des éléments à partir d'un observable.

N ° Sr.	Opérateur et description
1	Debounce Émet des éléments uniquement lorsque le délai expire sans émettre un autre élément.
2	Distinct Émet uniquement les éléments uniques.
3	ElementAt émettre uniquement un élément à n index émis par un observable.
4	Filter Émet uniquement les éléments qui passent la fonction de prédicat donnée.
5	First Émet le premier élément ou le premier élément qui a passé les critères donnés.
6	IgnoreElements N'émet aucun élément d'Observable mais marque la fin.
sept	Last Émet le dernier élément d'Observable.
8	Sample Émet l'élément le plus récent avec un intervalle de temps donné.
9	Skip Ignore les n premiers éléments d'un observable.
dix	SkipLast Ignore les n derniers éléments d'un observable.
11	Take prend les n premiers éléments d'un observable.
12	TakeLast prend les n derniers éléments d'un observable.

Exemple d'opérateur de filtrage

Créez le programme Java suivant en utilisant n'importe quel éditeur de votre choix dans, par exemple, 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);
   }
}