@Test public void resolveScopeFromLifecycle_normal_notComparable() { PublishSubject<IntHolder> lifecycle = PublishSubject.create(); TestObserver<?> o = testSource(resolveScopeFromLifecycle(lifecycle, new IntHolder(3))); lifecycle.onNext(new IntHolder(0)); o.assertNoErrors().assertNotComplete(); lifecycle.onNext(new IntHolder(1)); o.assertNoErrors().assertNotComplete(); lifecycle.onNext(new IntHolder(0)); o.assertNoErrors().assertNotComplete(); lifecycle.onNext(new IntHolder(2)); o.assertNoErrors().assertNotComplete(); lifecycle.onNext(new IntHolder(3)); o.assertComplete(); }
public static <E> CompletableSource resolveScopeFromLifecycle( final LifecycleScopeProvider<E> provider) throws OutsideScopeException { return resolveScopeFromLifecycle(provider, true); }
LifecycleScopes { public static <E> CompletableSource resolveScopeFromLifecycle( final LifecycleScopeProvider<E> provider) throws OutsideScopeException { return resolveScopeFromLifecycle(provider, true); } }
LifecycleScopes { public static <E> CompletableSource resolveScopeFromLifecycle( final LifecycleScopeProvider<E> provider) throws OutsideScopeException { return resolveScopeFromLifecycle(provider, true); } private  LifecycleScopes(); }
LifecycleScopes { public static <E> CompletableSource resolveScopeFromLifecycle( final LifecycleScopeProvider<E> provider) throws OutsideScopeException { return resolveScopeFromLifecycle(provider, true); } private  LifecycleScopes(); static CompletableSource resolveScopeFromLifecycle(
      final LifecycleScopeProvider<E> provider); static CompletableSource resolveScopeFromLifecycle(
      final LifecycleScopeProvider<E> provider, final boolean checkEndBoundary); static CompletableSource resolveScopeFromLifecycle(
      Observable<E> lifecycle, final E endEvent); static CompletableSource resolveScopeFromLifecycle(
      Observable<E> lifecycle, final E endEvent, @Nullable final Comparator<E> comparator); }
LifecycleScopes { public static <E> CompletableSource resolveScopeFromLifecycle( final LifecycleScopeProvider<E> provider) throws OutsideScopeException { return resolveScopeFromLifecycle(provider, true); } private  LifecycleScopes(); static CompletableSource resolveScopeFromLifecycle(
      final LifecycleScopeProvider<E> provider); static CompletableSource resolveScopeFromLifecycle(
      final LifecycleScopeProvider<E> provider, final boolean checkEndBoundary); static CompletableSource resolveScopeFromLifecycle(
      Observable<E> lifecycle, final E endEvent); static CompletableSource resolveScopeFromLifecycle(
      Observable<E> lifecycle, final E endEvent, @Nullable final Comparator<E> comparator);  }