RxJava - Operadores de filtragem

A seguir estão os operadores que são usados para emitir seletivamente item (ns) de um Observável.

Sr. Não.	Operador e descrição
1	Debounce Emite itens apenas quando o tempo limite ocorre sem emitir outro item.
2	Distinct Emite apenas itens exclusivos.
3	ElementAt emite apenas o item no índice n emitido por um Observable.
4	Filter Emite apenas os itens que passam pela função de predicado fornecida.
5	First Emite o primeiro item ou primeiro item que passou nos critérios fornecidos.
6	IgnoreElements Não emite nenhum item do Observável, mas marca a conclusão.
7	Last Emite o último elemento do Observable.
8	Sample Emite o item mais recente com determinado intervalo de tempo.
9	Skip Ignora os primeiros n itens de um Observável.
10	SkipLast Pula os últimos n itens de um Observável.
11	Take pega os primeiros n itens de um Observable.
12	TakeLast pega os últimos n itens de um Observable.

Exemplo de operador de filtragem

Crie o seguinte programa Java usando qualquer editor de sua escolha em, digamos, 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);
   }
}