Example of RxJava repeat and retry operators - DroidconIN 2016

Riddikulus.java

// Example of repeat and retry
  private Observable<Boggart> riddikulus() {
      return getBoggartObservable()
              .flatMap(new Func1<Boggart, Observable<Boggart>>() {
                  @Override
                  public Observable<Boggart> call(Boggart boggart) {
                      boggart.init();
                      boggart.riddikulus();
                      if (boggart.isFunny()) {
                          return Observable.just(boggart);
                      }
                      return Observable.error(new BoggartException());
                  }
              })
              .retry()
              .repeat(10) // repeat 10 times
              // take until Boggart is not Hilarious
              .takeUntil(new Func1<Boggart, Boolean>() { 
                  @Override
                  public Boolean call(Boggart boggart) {
                      return boggart.isHilarious();
                  }
              })
              // filter the input to only get the final Hilarious event
              .filter(new Func1<Boggart, Boolean>() { 
                  @Override
                  public Boolean call(Boggart boggart) {
                      return boggart.isHilarious();
                  }
              });
  }