RxJava - Creando Observables

Las siguientes son las clases base para crear observables.

• Flowable- 0..N flujos, emite 0 o n elementos. Soporta Reactive-Streams y contrapresión.

• Observable - Flujos 0..N, pero sin contrapresión.

• Single- 1 artículo o error. Puede tratarse como una versión reactiva de la llamada al método.

• Completable- Ningún artículo emitido. Se utiliza como señal de finalización o error. Puede tratarse como una versión reactiva de Runnable.

• MayBe- No se emitió ningún artículo o 1 artículo. Puede tratarse como una versión reactiva de Opcional.

A continuación se muestran los métodos convenientes para crear observables en la clase Observable.

• just(T item) - Devuelve un Observable que señala el elemento dado (referencia constante) y luego lo completa.

• fromIterable(Iterable source) - Convierte una secuencia Iterable en un ObservableSource que emite los elementos de la secuencia.

• fromArray(T... items) - Convierte una matriz en una fuente observable que emite los elementos de la matriz.

• fromCallable(Callable supplier) - Devuelve un Observable que, cuando un observador se suscribe, invoca una función que especifiques y luego emite el valor devuelto por esa función.

• fromFuture(Future future) - Convierte un futuro en una fuente observable.

• interval(long initialDelay, long period, TimeUnit unit) - Devuelve un Observable que emite un 0L después del InitialDelay y números cada vez mayores después de cada período de tiempo a partir de entonces.