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