RxJava retryWith example

rxjava-retrywith.java

// slide 75 of this: http://www.slideshare.net/Couchbase/reactive-programmingrxjavaefficientdata-benchristensenmichaelnitschinger

Observable.
  .defer(() -> bucket.get("id")) //create new
  .retryWhen(attempts -> attempts
      .zipWith(Observable.range(1,3), (n, i) -> i) // retry maximum of 3 times
      .flatMap(i -> {
        System.out.println("Delaying retry by " + i + " second(s)");
        return Observable.timer(i, TimeUnit.SECONDS); //delay the resubscribe
      })
  )
  .toBlocking()
  .forEach(System.out::println);