infinispan f22468305fa7c1c3a06492ef1e8c4e432b6a74f0

f22468305fa7c1c3a06492ef1e8c4e432b6a74f0

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 5

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Variable	1
Rename Variable extraThread : int to extraThreadCount : int in method protected exactlyOnceParallel(set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator Function<? super Publisher<I>,? extends CompletionStage<R>>, listener SegmentListener, concurrentSegments IntSet) : Flowable<R> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Extract Attribute	1
Extract Attribute package PARALLEL_BATCH_SIZE : int in class org.infinispan.reactive.publisher.impl.NonSegmentedLocalPublisherManagerImpl	From	To
Inline Variable	1
Inline Variable loaderPublisher : Publisher<K> in method public localPublisher(segments IntSet) : Publisher<K> from class org.infinispan.interceptors.impl.CacheLoaderInterceptor.WrappedKeySet	From	To
Extract Method	4
Extract Method private getKeyPublisher(inMemorySource Publisher<K>, segments IntSet) : Publisher<K> extracted from public localPublisher(segments IntSet) : Publisher<K> in class org.infinispan.interceptors.impl.CacheLoaderInterceptor.WrappedKeySet	From	To
Extract Method private getKeyPublisher(inMemorySource Publisher<K>, segments IntSet) : Publisher<K> extracted from public localPublisher(segment int) : Publisher<K> in class org.infinispan.interceptors.impl.CacheLoaderInterceptor.WrappedKeySet	From	To
Extract Method private getCacheEntryPublisher(inMemorySource Publisher<CacheEntry<K,V>>, segments IntSet) : Publisher<CacheEntry<K,V>> extracted from public localPublisher(segments IntSet) : Publisher<CacheEntry<K,V>> in class org.infinispan.interceptors.impl.CacheLoaderInterceptor.WrappedEntrySet	From	To
Extract Method private getCacheEntryPublisher(inMemorySource Publisher<CacheEntry<K,V>>, segments IntSet) : Publisher<CacheEntry<K,V>> extracted from public localPublisher(segment int) : Publisher<CacheEntry<K,V>> in class org.infinispan.interceptors.impl.CacheLoaderInterceptor.WrappedEntrySet	From	To
Rename Parameter	12
Rename Parameter transformer : Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> to collator : Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> in method public entryReduction(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, collator Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<K>,? extends CompletionStage<R>> to collator : Function<? super Publisher<K>,? extends CompletionStage<R>> in method private handleSpecificKeys(parallelPublisher boolean, keysToInclude Set<K>, keysToExclude Set<K>, deliveryGuarantee DeliveryGuarantee, collator Function<? super Publisher<K>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method private atLeastOnce(parallel boolean, cacheSet CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator 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
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method private atMostOnce(parallel boolean, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method protected exactlyOnceParallel(set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator Function<? super Publisher<I>,? extends CompletionStage<R>>, listener SegmentListener, concurrentSegments IntSet) : Flowable<R> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method private parallelAtMostOnce(cacheSet CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method protected exactlyOnceSequential(set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator Function<? super Publisher<I>,? extends CompletionStage<R>>, listener SegmentListener, concurrentSegments IntSet) : Flowable<R> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method private handleParallelSegment(segmentIter PrimitiveIterator.OfInt, initialSegment int, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, collator Function<? super Publisher<I>,? extends CompletionStage<R>>, processor FlowableProcessor<R>, concurrentSegments IntSet, listener SegmentListener) : void in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> to collator : Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> in method private handleSpecificEntries(parallelPublisher boolean, keysToInclude Set<K>, keysToExclude Set<K>, deliveryGuarantee DeliveryGuarantee, collator Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<K>,? extends CompletionStage<R>> to collator : Function<? super Publisher<K>,? extends CompletionStage<R>> in method public keyReduction(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, keysToExclude Set<K>, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, collator Function<? super Publisher<K>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<PublisherResult<R>> in class org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl	From	To
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method private exactlyOnce(parallelPublisher boolean, set CacheSet<I>, keysToExclude Set<K>, toKeyFunction Function<I,K>, segments IntSet, collator 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
Rename Parameter transformer : Function<? super Publisher<I>,? extends CompletionStage<R>> to collator : Function<? super Publisher<I>,? extends CompletionStage<R>> in method private handleSpecificObjects(parallelPublisher boolean, keysToInclude Set<K>, keysToExclude Set<K>, keyTransformer Function<? super Flowable<K>,? extends Flowable<I>>, collator 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

f22468305fa7c1c3a06492ef1e8c4e432b6a74f0

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: