public static boolean onNext()

in autodispose/src/main/java/autodispose2/HalfSerializer.java [120:134]

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

  public static <@NonNull T> boolean onNext(Observer<? super T> observer, T value, AtomicInteger wip, AtomicThrowable error) {
    if (wip.get() == 0 && wip.compareAndSet(0, 1)) {
      observer.onNext(value);
      if (wip.decrementAndGet() != 0) {
        Throwable ex = error.terminate();
        if (ex != null) {
          observer.onError(ex);
        } else {
          observer.onComplete();
        }
        return true;
      }
    }
    return false;
  }