public static void onComplete()

in autodispose/src/main/java/autodispose2/HalfSerializer.java [98:107]

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

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