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