Chain.java

public Observable<Rates> getRates() {
    String accessToken = getAuthenticationTokens().getAccessToken();
    return networking.getRates(accessToken)
            .flatMap(new Func1<Response<Rates>, Observable<Rates>>() {
                @Override
                public Observable<Rates> call(Response<Rates> response) {
                    if (response.isSuccess()) {
                        Rates rates = response.body();
                        return Observable.just(rates);
                    }

                    switch (response.code()) {
                        case 401:
                            return exchangeRefreshToken()
                                    .doOnNext(new Action1<AuthenticationTokens>() {
                                        @Override
                                        public void call(AuthenticationTokens authenticationTokens) {
                                            saveAuthenticationTokens(authenticationTokens);
                                        }
                                    }).flatMap(new Func1<AuthenticationTokens, Observable<Rates>>() {
                                        @Override
                                        public Observable<Rates> call(AuthenticationTokens authenticationTokens) {
                                            return getRates();
                                        }
                                    });

                    }

                    return Observable.error(ErrorParser.parseBody(response.errorBody()));
                }
            });
}