RxJava - Criando Operadores

A seguir estão os operadores que são usados ​​para criar um Observable.

Sr. Não.	Operador e descrição
1	Create Cria um Observable do zero e permite que o método do observador chame programaticamente.
2	Defer Não crie um Observable até que um observador se inscreva. Cria um novo observável para cada observador.
3	Empty/Never/Throw Cria um observável com comportamento limitado.
4	From Converte uma estrutura de objeto / dados em um Observable.
5	Interval Cria um número inteiro de emissão observável em sequência com um intervalo de intervalo de tempo especificado.
6	Just Converte uma estrutura de objeto / dados em um Observable para emitir o mesmo ou o mesmo tipo de objetos.
7	Range Cria um número inteiro de emissão observável na sequência de um determinado intervalo.
8	Repeat Cria um observável emitindo inteiros em sequência repetidamente.
9	Start Cria um Observable para emitir o valor de retorno de uma função.
10	Timer Cria um Observable para emitir um único item após um determinado atraso.

Criando exemplo de operador

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

ObservableTester.java

import io.reactivex.Observable;
//Using fromArray operator to create 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
         .map(String::toUpperCase)
         .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