coordinated-retry-with-dealy.java

// from: http://www.slideshare.net/Couchbase/reactive-programmingrxjavaefficientdata-benchristensenmichaelnitschinger/75

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