public static void onError()

in autodispose/src/main/java/autodispose2/HalfSerializer.java [80:88]

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

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