static long add()

in autodispose/src/main/java/autodispose2/AutoDisposeBackpressureHelper.java [53:64]

• 12 lines of code
• 4 McCabe index (conditional complexity)

  static long add(AtomicLong requested, long n) {
    for (; ; ) {
      long r = requested.get();
      if (r == Long.MAX_VALUE) {
        return Long.MAX_VALUE;
      }
      long u = addCap(r, n);
      if (requested.compareAndSet(r, u)) {
        return r;
      }
    }
  }