private void checkToUpdateSubscription()

in mobius-extras/src/main/java/com/spotify/mobius/extras/ToggledEventSource.java [82:95]

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

  private void checkToUpdateSubscription() {
    synchronized (consumers) {
      if (!active || consumers.size() == 0) {
        if (disposable != null) {
          disposable.dispose();
        }
        disposable = null;
      } else {
        if (disposable == null) {
          disposable = targetEventSource.subscribe(this::onValueEmitted);
        }
      }
    }
  }