public void onSubscribe()

in autodispose/src/main/java/autodispose2/AutoDisposingSubscriberImpl.java [55:77]

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

  public void onSubscribe(final Subscription s) {
    DisposableCompletableObserver o =
        new DisposableCompletableObserver() {
          @Override
          public void onError(Throwable e) {
            scopeDisposable.lazySet(AutoDisposableHelper.DISPOSED);
            AutoDisposingSubscriberImpl.this.onError(e);
          }

          @Override
          public void onComplete() {
            scopeDisposable.lazySet(AutoDisposableHelper.DISPOSED);
            AutoSubscriptionHelper.cancel(mainSubscription);
          }
        };
    if (AutoDisposeEndConsumerHelper.setOnce(scopeDisposable, o, getClass())) {
      delegate.onSubscribe(this);
      scope.subscribe(o);
      if (AutoDisposeEndConsumerHelper.setOnce(mainSubscription, s, getClass())) {
        AutoSubscriptionHelper.deferredSetOnce(ref, requested, s);
      }
    }
  }