public static void onError()

in autodispose/src/main/java/autodispose2/HalfSerializer.java [146:154]

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

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