public static CompletableSource resolveScopeFromLifecycle()

in autodispose-lifecycle/src/main/java/autodispose2/lifecycle/LifecycleScopes.java [137:146]

• 10 lines of code
• 2 McCabe index (conditional complexity)

  public static <@NonNull E> CompletableSource resolveScopeFromLifecycle(
      Observable<E> lifecycle, final E endEvent, @Nullable final Comparator<E> comparator) {
    Predicate<E> equalityPredicate;
    if (comparator != null) {
      equalityPredicate = e -> comparator.compare(e, endEvent) >= 0;
    } else {
      equalityPredicate = e -> e.equals(endEvent);
    }
    return lifecycle.skip(1).takeUntil(equalityPredicate).ignoreElements();
  }