Session Renew Problem - DroidconIN 2016

Repeatium.java

// Use concat and repeat to renew the session repeatedly    
 Observable<Session> getRenewedSession() {
       Observable<Session> sessionObservable = 
       SessionManager.getCurrentSessionObservable()
               .filter(new Func1<Session, Boolean>() {
                   @Override
                   public Boolean call(Session session) {
                       return session.isValid();
                   }
               });
       Observable<Session> renewSession =
               SessionManager.getCurrentSessionObservable()
               .flatMap(new Func1<Session, Observable<Session>>() {
                   @Override
                   public Observable<Session> call(Session session) {
                       return authService.renewSession(session.getSessionId())
                               .repeatWhen(
                                new Func1<Observable<? extends Void>, Observable<?>>() {
                                   @Override
                                   public Observable<?> call(
                                    Observable<? extends Void> observable) {
                                       return observable.delay(
                                        Session.EXPIRY_TIME_IN_MILLIS,
                                               TimeUnit.MILLISECONDS);
                                   }
                               });
                   }
               });
       return sessionObservable.concatWith(renewSession);
   }