Programación Reactiva con RxJava

Capítulo 3. Operadores y transformaciones

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: [e-mail]

Tomasz Nurkiewicz

El objetivo de este capítulo es explicar los fundamentos de los operadores de RxJava y cómo puedes componerlos para construir canalizaciones de datos de alto nivel y fáciles de razonar. Una de las razones por las que RxJava es tan potente es el rico universo de operadores incorporados que proporciona y la posibilidad de crear otros personalizados. Un operador es una función que toma Observable<T> en sentido ascendente y devuelve Observable<R> en sentido descendente, donde los tipos T y R pueden ser iguales o no. Los operadores permiten componer transformaciones sencillas en grafos de procesamiento complejos.

Por ejemplo, el operador Observable.filter() recibe elementos de un Observable ascendente, pero sólo reenvía los que coinciden con un predicado determinado. A la inversa, Observable.map() transforma los elementos que recibe a medida que pasan. Esto permite extraer, enriquecer o envolver eventos originales. Algunos operadores son mucho más complicados. Por ejemplo, Observable.delay() hará pasar los eventos tal cual; sin embargo, todos y cada uno de ellos aparecerán tras un retardo fijo. Por último, hay operadores (como Observable.buffer()) que consumen varios eventos de entrada antes de emitirlos, posiblemente por lotes.

Pero incluso cuando reconozcas lo maravillosos que son los operadores Rx, el verdadero ...