RxJava - Creazione di operatori

Di seguito sono riportati gli operatori utilizzati per creare un osservabile.

Sr.No. Operatore e descrizione
1

Create

Crea un Observable da zero e consente al metodo dell'osservatore di chiamare a livello di codice.
2

Defer

Non creare un osservabile fino a quando un osservatore non si abbona. Crea un nuovo osservabile per ogni osservatore.
3

Empty/Never/Throw

Crea un osservabile con un comportamento limitato.
4

From

Converte una struttura oggetto / dati in un osservabile.
5

Interval

Crea un osservabile che emette numeri interi in sequenza con un intervallo di intervallo di tempo specificato.
6

Just

Converte una struttura oggetto / dati in un osservabile per emettere lo stesso o lo stesso tipo di oggetti.
7

Range

Crea un Osservabile che emette numeri interi in una sequenza di un dato intervallo.
8

Repeat

Crea un osservabile che emette numeri interi in sequenza ripetutamente.
9

Start

Crea un oggetto Observable per emettere il valore restituito di una funzione.
10

Timer

Crea un osservabile per emettere un singolo oggetto dopo un determinato ritardo.

Creazione di un esempio di operatore

Crea il seguente programma Java utilizzando qualsiasi editor di tua scelta, ad esempio 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);
   }
}

Verifica il risultato

Compila la classe usando javac compilatore come segue -

C:\RxJava>javac ObservableTester.java

Ora esegui ObservableTester come segue:

C:\RxJava>java ObservableTester

Dovrebbe produrre il seguente output:

ABCDEFG