protected void subscribeActual()

in android/autodispose-androidx-lifecycle/src/main/java/autodispose2/androidx/lifecycle/LifecycleEventsObservable.java [79:92]

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

  protected void subscribeActual(Observer<? super Event> observer) {
    AutoDisposeLifecycleObserver lifecycleObserver =
        new AutoDisposeLifecycleObserver(lifecycle, observer, eventsObservable);
    observer.onSubscribe(lifecycleObserver);
    if (!isMainThread()) {
      observer.onError(
          new IllegalStateException("Lifecycles can only be bound to on the main thread!"));
      return;
    }
    lifecycle.addObserver(lifecycleObserver);
    if (lifecycleObserver.isDisposed()) {
      lifecycle.removeObserver(lifecycleObserver);
    }
  }