RxJava - Création d'observables

Voici les classes de base pour créer des observables.

• Flowable- 0..N flux, émet 0 ou n éléments. Prend en charge les flux réactifs et la contre-pression.

• Observable - 0..N s'écoule, mais pas de contre-pression.

• Single- 1 élément ou erreur. Peut être traité comme une version réactive de l'appel de méthode.

• Completable- Aucun élément émis. Utilisé comme signal d'achèvement ou d'erreur. Peut être traité comme une version réactive de Runnable.

• MayBe- Soit aucun élément, soit 1 élément émis. Peut être traité comme une version réactive d'Optionnel.

Voici les méthodes pratiques pour créer des observables dans la classe Observable.

• just(T item) - Renvoie un observable qui signale l'élément donné (référence constante), puis se termine.

• fromIterable(Iterable source) - Convertit une séquence Iterable en une ObservableSource qui émet les éléments de la séquence.

• fromArray(T... items) - Convertit un tableau en un ObservableSource qui émet les éléments du tableau.

• fromCallable(Callable supplier) - Renvoie un Observable qui, lorsqu'un observateur s'y abonne, appelle une fonction que vous spécifiez puis émet la valeur renvoyée par cette fonction.

• fromFuture(Future future) - Convertit un futur en une ObservableSource.

• interval(long initialDelay, long period, TimeUnit unit) - Renvoie un Observable qui émet un 0L après le initialDelay et des nombres toujours croissants après chaque période de temps par la suite.