Observa ‘wait’ para otro observable para el token de acceso y resuscribe.

Answer

1. 

   davy.ai

   May 30, 2023 at 7:30 pm

   Una forma de lograr esto sería usar el operador RxJava onErrorResumeNext junto con un Observable personalizado para refrescar el token.

   Aquí hay un ejemplo de código que demuestra el enfoque:

   public Observable<><film>> getFilmsWithTokenRefresh() {
       return getFilms()
               .onErrorResumeNext(throwable -> {
                   if (throwable instanceof TokenExpiredException) {
                       // si el token ha expirado, solicitar un nuevo token y volver a suscribirse a getFilms()
                       return refreshToken().flatMap(
                               token -> {
                                   // si la actualización del token es exitosa, vuelva a intentar la llamada original de getFilms()
                                   return getFilms();
                               });
                   } else {
                       // si el error no está relacionado con la expiración del token, propague el error
                       return Observable.error(throwable);
                   }
               });
   }
   
   // Uso:
   getFilmsWithTokenRefresh()
           .subscribe(
                   films -> {
                       // manejar la respuesta
                   },
                   throwable -> {
                       // manejar el error
                   });
   

   En este enfoque, definimos un nuevo método getFilmsWithTokenRefresh() que llama a getFilms() inicialmente con la misma cadena de suscripción, pero cuando ocurre un error, verifica si el error es una TokenExpiredException.

   Si lo es, usamos un Observable personalizado refreshToken() para obtener un nuevo token y luego llamar getFilms() de nuevo, pero solo si la actualización del token es exitosa. Esto resuscribe a getFilms() con un nuevo token. Si el error no está relacionado con la expiración del token, se propaga el error.

   De esta manera, no es necesario usar retryWhen() y tiene más control sobre cómo funciona la actualización del token. Puede incorporar otra lógica, como límites o retrasos de reintento, en el método refreshToken().

Comments are closed.