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

Verifique o resultado

Compile a classe usando javac compilador da seguinte forma -

C:\RxJava>javac ObservableTester.java

Agora execute o ObservableTester da seguinte maneira -

C:\RxJava>java ObservableTester

Ele deve produzir a seguinte saída -

ab