public static boolean setOnce()

in autodispose/src/main/java/autodispose2/AutoDisposeEndConsumerHelper.java [50:60]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  public static boolean setOnce(AtomicReference<Disposable> upstream, Disposable next, Class<?> observer) {
    AutoDisposeUtil.checkNotNull(next, "next is null");
    if (!upstream.compareAndSet(null, next)) {
      next.dispose();
      if (upstream.get() != AutoDisposableHelper.DISPOSED) {
        reportDoubleSubscription(observer);
      }
      return false;
    }
    return true;
  }