public static void onComplete()

in autodispose/src/main/java/autodispose2/HalfSerializer.java [164:173]

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

  public static void onComplete(Observer<?> observer, AtomicInteger wip, AtomicThrowable error) {
    if (wip.getAndIncrement() == 0) {
      Throwable ex = error.terminate();
      if (ex != null) {
        observer.onError(ex);
      } else {
        observer.onComplete();
      }
    }
  }