RxJava - Creación de operadores

A continuación se muestran los operadores que se utilizan para crear un Observable.

No Señor.	Operador y descripción
1	Create Crea un Observable desde cero y permite que el método del observador llame mediante programación.
2	Defer No cree un Observable hasta que un observador se suscriba. Crea un observable nuevo para cada observador.
3	Empty/Never/Throw Crea un Observable con comportamiento limitado.
4	From Convierte una estructura de objeto / datos en un Observable.
5	Interval Crea un Observable que emite enteros en secuencia con un intervalo de intervalo de tiempo especificado.
6	Just Convierte un objeto / estructura de datos en un Observable para emitir el mismo o el mismo tipo de objetos.
7	Range Crea un Observable que emite enteros en secuencia de un rango dado.
8	Repeat Crea un Observable emitiendo enteros en secuencia repetidamente.
9	Start Crea un Observable para emitir el valor de retorno de una función.
10	Timer Crea un Observable para emitir un solo elemento después de un retraso determinado.

Ejemplo de creación de operador

Cree el siguiente programa Java utilizando cualquier editor de su elección en, 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);
   }
}

Verificar el resultado

Compila la clase usando javac compilador de la siguiente manera:

C:\RxJava>javac ObservableTester.java

Ahora ejecute ObservableTester de la siguiente manera:

C:\RxJava>java ObservableTester

Debería producir el siguiente resultado:

ABCDEFG