|
Rename Method public testCountExcludedKeys(deliveryGuarantee DeliveryGuarantee, parallel boolean, isEntry boolean) : void renamed to public testCountWithContext(deliveryGuarantee DeliveryGuarantee, parallel boolean, isEntry boolean) : void in class org.infinispan.reactive.publisher.impl.SimpleClusterPublisherManagerTest |
From |
To |
|
Rename Method public sumFinalizer() : Function<Publisher<Long>,CompletionStage<Long>> renamed to public add() : Function<Publisher<Long>,CompletionStage<Long>> in class org.infinispan.reactive.publisher.PublisherReducers |
From |
To |
|
Rename Method public sumReducer() : Function<Publisher<?>,CompletionStage<Long>> renamed to public count() : Function<Publisher<?>,CompletionStage<Long>> in class org.infinispan.reactive.publisher.PublisherReducers |
From |
To |
|
Change Parameter Type keysToExclude : Set<K> to ctx : InvocationContext in method private startKeyPublisher(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, composedType ComposedType<K,I,R>, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>, flowableProcessor FlowableProcessor<R>) : void in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Change Parameter Type keysToExclude : Set<K> to ctx : InvocationContext in method public entryReduction(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, transformer Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Change Parameter Type keysToExclude : Set<K> to ctx : InvocationContext in method public keyReduction(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, transformer Function<? super Publisher<K>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Change Parameter Type cache : Cache<Integer,String> to kp : KeyPartitioner in method private findHowManyInSegments(insertAmount int, targetSegments IntSet, kp KeyPartitioner) : int in class org.infinispan.reactive.publisher.impl.SimpleClusterPublisherManagerTest |
From |
To |
|
Change Parameter Type keysToExclude : Set<K> to ctx : InvocationContext in method package SegmentSpecificConsumer(flowableProcessor FlowableProcessor<R>, parallelCount AtomicInteger, currentTopologyId int, parallelPublisher boolean, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, composedType ComposedType<K,I,R>, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SegmentSpecificConsumer |
From |
To |
|
Change Parameter Type object : IdentifyFinishCollector to object : CacheStreamIntermediateReducer in method public writeObject(output ObjectOutput, object CacheStreamIntermediateReducer) : void in class org.infinispan.stream.impl.CacheStreamIntermediateReducer.ReducerExternalizer |
From |
To |
|
Change Parameter Type keysToExclude : Set<K> to ctx : InvocationContext in method private startSegmentPublisher(parallelPublisher boolean, segments IntSet, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, composedType ComposedType<K,I,R>, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>, flowableProcessor FlowableProcessor<R>) : void in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Rename Parameter keysToExclude : Set<K> to ctx : InvocationContext in method public keyReduction(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, transformer Function<? super Publisher<K>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Rename Parameter cache : Cache<Integer,String> to kp : KeyPartitioner in method private findHowManyInSegments(insertAmount int, targetSegments IntSet, kp KeyPartitioner) : int in class org.infinispan.reactive.publisher.impl.SimpleClusterPublisherManagerTest |
From |
To |
|
Rename Parameter keysToExclude : Set<K> to ctx : InvocationContext in method package SegmentSpecificConsumer(flowableProcessor FlowableProcessor<R>, parallelCount AtomicInteger, currentTopologyId int, parallelPublisher boolean, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, composedType ComposedType<K,I,R>, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SegmentSpecificConsumer |
From |
To |
|
Rename Parameter keysToExclude : Set<K> to ctx : InvocationContext in method private startSegmentPublisher(parallelPublisher boolean, segments IntSet, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, composedType ComposedType<K,I,R>, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>, flowableProcessor FlowableProcessor<R>) : void in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Rename Parameter keysToExclude : Set<K> to ctx : InvocationContext in method private startKeyPublisher(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, composedType ComposedType<K,I,R>, transformer Function<? super Publisher<I>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>, flowableProcessor FlowableProcessor<R>) : void in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |
|
Rename Parameter keysToExclude : Set<K> to ctx : InvocationContext in method public entryReduction(parallelPublisher boolean, segments IntSet, keysToInclude Set<K>, ctx InvocationContext, includeLoader boolean, deliveryGuarantee DeliveryGuarantee, transformer Function<? super Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>>, finalizer Function<? super Publisher<R>,? extends CompletionStage<R>>) : CompletionStage<R> in class org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl |
From |
To |