RxJava2 + Retrofit 2. Modificamos el adaptador para manejar la falta de estado de Internet en Android

Muy a menudo es necesario hacer solicitudes repetidas a la red, por ejemplo, cuando el usuario no tenía Internet y quería recibir datos de Internet. Sería bueno volver a lanzar la solicitud cuando aparezca. Es una buena práctica mostrarle al usuario una IU específica que le explique lo que sucedió y permita que la solicitud se vuelva a lanzar. Agregar esa lógica puede ser bastante doloroso, especialmente cuando tenemos una gran cantidad de clases ViewModel. Por supuesto, puede implementar la lógica de nueva consulta en cada clase de ViewModel, pero esto no es conveniente y hay una gran probabilidad de errores.

¿Hay alguna manera de hacer este procesamiento solo una vez?

Afortunadamente, RxJava2 y Retrofit2 lo permiten.

Ya hay varias soluciones en Stackoverflow:

1. Creando tu propia CallAdapterFactory (más información aquí )
2. Repita la cadena usando PublishSubject (más información aquí )

La primera solución usa RxJava1, ya está desactualizada y también simplemente repite la cadena varias veces, sin reaccionar ante la ocurrencia del evento. La segunda solución es buena, pero necesitamos usar el reintentoCuando el operador en cada cadena. Y así, combiné las dos soluciones en una.

Implementación

Creemos un proyecto simple. Coloque dos pestañas en la pantalla principal. Cada uno de ellos muestra un texto que mostrará cuántos elementos carga la API. Si se produce un error durante la ejecución, mostramos una SnackBar con un botón Intentar de nuevo.



Definimos clases base como BaseActivity, BaseFragment, BaseViewModel, son necesarias para implementar la lógica de la repetición de solicitudes en un lugar y evitar la duplicación de este código. Crea dos fragmentos que extenderán BaseFragment. Cada fragmento colocado tiene su propio ViewModel y realiza solicitudes de forma independiente a la API. Creé estos fragmentos para mostrar que si se produce un error, se repetirá cada solicitud. A continuación, cree una fábrica RxRetryCallAdapterFactory que extienda CallAdapter.Factory. Después de eso, cree una instancia de RxJava2CallAdapterFactory. Necesitamos esta instancia para acceder al RxJava2CallAdapter, ya que no queremos duplicar el código que ya está en la biblioteca Retrofit. Además, creemos un método estático que devolverá una instancia de nuestra fábrica. Código de muestra a continuación:

class RxRetryCallAdapterFactory : CallAdapter.Factory() { companion object { fun create() : CallAdapter.Factory = RxRetryCallAdapterFactory() } private val originalFactory = RxJava2CallAdapterFactory.create() override fun get(returnType : Type, annotations : Array<Annotation>, retrofit : Retrofit) : CallAdapter<*, *>? { val adapter = originalFactory.get(returnType, annotations, retrofit) ?: return null return RxRetryCallAdapter(adapter) } } 

A continuación, cree un RxRetryCallAdapter que implemente la interfaz CallAdapter y necesitemos pasar la instancia de CallAdapter al constructor. De hecho, debe ser una instancia de RxJava2CallAdapter, que devuelve la fábrica original.

Luego, necesitamos implementar las siguientes cosas:

• retryCuando la instrucción utilizada para implementar la funcionalidad de repetición
• sentencia doOnError () que maneja los errores. Se utiliza para enviar la transmisión, que se procesa en BaseActivity y muestra la SnackBar al usuario.
• PublishSubject se utiliza como desencadenante de eventos que vuelve a firmar la cadena.
• Operador observeOn (Schedulers.io ()) que debe aplicarse a PublishSubject (si no se agrega esta línea, la suscripción se realizará en el hilo principal y obtendremos una NetworkOnMainThreadException
• Transformamos PublishSubject en Flowable y establecemos BackpressureStrategy.LATEST, ya que solo necesitamos el último error

Nota: Para proporcionar PublishSubject, creé una clase singleton simple que expone todas las dependencias singleton en el proyecto. En un proyecto real, es probable que use un marco de inyección de dependencia como Dagger2

 class RxRetryCallAdapter<R>(private val originalAdapter : CallAdapter<R, *>) : CallAdapter<R, Any> { override fun adapt(call : Call<R>) : Any { val adaptedValue = originalAdapter.adapt(call) return when (adaptedValue) { is Completable -> { adaptedValue.doOnError(this::sendBroadcast) .retryWhen { AppProvider.provideRetrySubject().toFlowable(BackpressureStrategy.LATEST) .observeOn(Schedulers.io()) } } is Single<*> -> { adaptedValue.doOnError(this::sendBroadcast) .retryWhen { AppProvider.provideRetrySubject().toFlowable(BackpressureStrategy.LATEST) .observeOn(Schedulers.io()) } } //same for Maybe, Observable, Flowable else -> { adaptedValue } } } override fun responseType() : Type = originalAdapter.responseType() private fun sendBroadcast(throwable : Throwable) { Timber.e(throwable) LocalBroadcastManager.getInstance(AppProvider.appInstance).sendBroadcast(Intent(BaseActivity.ERROR_ACTION)) } } 

Cuando el usuario hace clic en el botón Intentar de nuevo, llamamos al siguiente PublishSubject. Después de eso, nos volvemos a suscribir a la cadena rx.

Prueba

Apague Internet y ejecute la aplicación. El número de elementos cargados es cero en cada pestaña y SnackBar muestra un error. Encienda Internet y haga clic en Probar Adain. Después de unos segundos, el número de elementos cargados cambia en cada una de las pestañas.



Si alguien lo necesita, entonces el código fuente está aquí