RxJava - Operadores de serviços públicos

A seguir estão os operadores que geralmente são úteis com Observáveis.

Sr. Não. Operador e descrição
1

Delay

Registre a ação para lidar com eventos de ciclo de vida observáveis.

2

Materialize/Dematerialize

Representa o item emitido e a notificação enviada.

3

ObserveOn

Especifique o planejador a ser observado.

4

Serialize

Força Observable a fazer chamadas serializadas.

5

Subscribe

Operar sobre as emissões de itens e notificações como concluídas de um Observável

6

SubscribeOn

Especifique o planejador a ser usado por um Observable quando ele for inscrito.

7

TimeInterval

Converta um Observável para emitir indicações da quantidade de tempo decorrido entre as emissões.

8

Timeout

Emite notificação de erro se o tempo especificado ocorrer sem a emissão de nenhum item.

9

Timestamp

Anexe o carimbo de data / hora a cada item emitido.

9

Using

Cria um recurso descartável ou mesmo tempo de vida do Observable.

Exemplo de operador de serviço público

Crie o seguinte programa Java usando qualquer editor de sua escolha em, digamos, C: \> RxJava.

ObservableTester.java

import io.reactivex.Observable;
//Using subscribe operator to subscribe to 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.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 -

abcdefg