RxJava - Creazione di osservabili
Di seguito sono riportate le classi base per creare osservabili.
Flowable- 0..N flussi, emette 0 o n elementi. Supporta flussi reattivi e contropressione.
Observable - 0..N flussi, ma nessuna contropressione.
Single- 1 articolo o errore. Può essere trattato come una versione reattiva della chiamata al metodo.
Completable- Nessun elemento emesso. Utilizzato come segnale di completamento o errore. Può essere trattato come una versione reattiva di Runnable.
MayBe- Nessun elemento o 1 elemento emesso. Può essere trattato come una versione reattiva di Opzionale.
Di seguito sono riportati i metodi convenienti per creare osservabili nella classe Observable.
just(T item) - Restituisce un osservabile che segnala l'elemento dato (riferimento costante) e quindi completa.
fromIterable(Iterable source) - Converte una sequenza Iterable in un ObservableSource che emette gli elementi nella sequenza.
fromArray(T... items) - Converte un array in un ObservableSource che emette gli elementi nell'array.
fromCallable(Callable supplier) - Restituisce un Observable che, quando un osservatore si iscrive ad esso, richiama una funzione specificata e quindi emette il valore restituito da quella funzione.
fromFuture(Future future) - Converte un futuro in una ObservableSource.
interval(long initialDelay, long period, TimeUnit unit) - Restituisce un Observable che emette uno 0L dopo il initialDelay e numeri sempre crescenti dopo ogni periodo di tempo successivo.