71d8cc7e9ca611afae10f2add928467cbbd190ea
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable stageFlowable : Flowable<CompletionStage<R>> to resultFlowable : Flowable<R> in method private exactlyOnce(parallelPublisher boolean, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl | From | To | |
| Change Return Type | 2 | ||
| Change Return Type Flowable<K> to Publisher<K> in method public publishKeys(filter Predicate<? super K>) : Publisher<K> in class org.infinispan.persistence.support.ComposedSegmentedLoadWriteStore | From | To | |
| Change Return Type Flowable<K> to Publisher<K> in method public publishKeys(segments IntSet, filter Predicate<? super K>) : Publisher<K> in class org.infinispan.persistence.support.ComposedSegmentedLoadWriteStore | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type stageFlowable : Flowable<CompletionStage<R>> to resultFlowable : Flowable<R> in method private exactlyOnce(parallelPublisher boolean, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl | From | To | |
| Extract Variable | 2 | ||
| Extract Variable publisherFunction : IntFunction<Publisher<K>> in method public publishKeys(segments IntSet, filter Predicate<? super K>) : Publisher<K> from class org.infinispan.persistence.support.ComposedSegmentedLoadWriteStore | From | To | |
| Extract Variable publisherFunction : IntFunction<Publisher<MarshallableEntry<K,V>>> in method public entryPublisher(segments IntSet, filter Predicate<? super K>, fetchValue boolean, fetchMetadata boolean) : Publisher<MarshallableEntry<K,V>> from class org.infinispan.persistence.support.ComposedSegmentedLoadWriteStore | From | To | |
| Extract Method | 3 | ||
| Extract Method protected exactlyOnceSequential(set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, listener SegmentListener, concurrentSegments IntSet) : Flowable<R> extracted from private exactlyOnce(parallelPublisher boolean, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl | From | To | |
| Extract Method protected exactlyOnceHandleLostSegments(finalValue CompletionStage<R>, listener SegmentListener) : CompletionStage<PublisherResult<R>> extracted from private exactlyOnce(parallelPublisher boolean, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl | From | To | |
| Extract Method protected combineStages(stagePublisher Flowable<? extends CompletionStage<R>>) : Flowable<R> extracted from private combineStages(stagePublisher Flowable<? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl | From | To |