retryWhen.java

retryWhen(new Func1<Observable<? extends Throwable>, Observable<?>>() {
    @Override
    public Observable<?> call(Observable<? extends Throwable> observable) {
        Log.v(TAG, "retryWhen, call");

        return observable.zipWith(Observable.range(COUNTER_START, ATTEMPTS), new Func2<Throwable, Integer, Integer>() {
            @Override
            public Integer call(Throwable throwable, Integer attempt) {
                Log.v(TAG, "zipWith, call, attempt " + attempt);
                return attempt;
            }
      })