static void deferredRequest()

in autodispose/src/main/java/autodispose2/AutoSubscriptionHelper.java [246:263]

• 17 lines of code
• 5 McCabe index (conditional complexity)

  static void deferredRequest(AtomicReference<Subscription> field, AtomicLong requested, long n) {
    Subscription s = field.get();
    if (s != null) {
      s.request(n);
    } else {
      if (AutoSubscriptionHelper.validate(n)) {
        AutoDisposeBackpressureHelper.add(requested, n);

        s = field.get();
        if (s != null) {
          long r = requested.getAndSet(0L);
          if (r != 0L) {
            s.request(r);
          }
        }
      }
    }
  }