code: public static <T> Observable<T> wrapForRetry(Observable<T> source, int maxAttempts) {
          return wrapForRetry(source, new RetryWithDelayHandler(maxAttempts, DEFAULT_DELAY));
      }
docs: Wrap an {@link Observable} so that it will retry on all errors for a maximum number of times.
  The retry is almost immediate (1ms delay).
  
  @param source the {@link Observable} to wrap.
  @param maxAttempts the maximum number of times to attempt a retry. It will be capped at <code>{@link Integer#MAX_VALUE} - 1</code>.
  @param <T> the type of items emitted by the source Observable.
  @return the wrapped retrying Observable.