RxJava - Operatori di utilità

Di seguito sono riportati gli operatori che sono spesso utili con gli osservabili.

Sr.No. Operatore e descrizione
1

Delay

Registra l'azione per gestire gli eventi osservabili del ciclo di vita.
2

Materialize/Dematerialize

Rappresenta l'elemento emesso e la notifica inviata.
3

ObserveOn

Specificare lo scheduler da osservare.
4

Serialize

Forza Observable per effettuare chiamate serializzate.
5

Subscribe

Agisci sulle emissioni di oggetti e notifiche come se fosse completo da un osservabile
6

SubscribeOn

Specificare lo scheduler che deve essere utilizzato da un Observable quando è sottoscritto.
7

TimeInterval

Convertire un osservabile per emettere indicazioni del tempo trascorso tra le emissioni.
8

Timeout

Emette una notifica di errore se il tempo specificato si verifica senza l'emissione di alcun elemento.
9

Timestamp

Allega timestamp a ogni elemento emesso.
9

Using

Crea una risorsa usa e getta o la stessa durata di quella di Observable.

Esempio di operatore di utilità

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

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