|
Change Parameter Type completionListener : KeyWatchingCompletionListener to userListener : Consumer<? super Supplier<PrimitiveIterator.OfInt>> in method package CompletionRehashPublisherDecorator(iteratorOperation AbstractCacheStream.IteratorOperation, dm DistributionManager, localAddress Address, userListener Consumer<? super Supplier<PrimitiveIterator.OfInt>>, completedSegments Consumer<? super Supplier<PrimitiveIterator.OfInt>>, lostSegments Consumer<? super Supplier<PrimitiveIterator.OfInt>>, keyConsumer Consumer<Object>) in class org.infinispan.stream.impl.CompletionRehashPublisherDecorator |
From |
To |
|
Change Parameter Type kwcl : KeyWatchingCompletionListener to crpd : CompletionRehashPublisherDecorator<Object> in method package simpleAssert(resultingPublisher Publisher<Object>, valuePublisher PublishProcessor<Object>, segmentConsumer Consumer<Supplier<PrimitiveIterator.OfInt>>, crpd CompletionRehashPublisherDecorator<Object>, notifySegmentsCompleted Consumer<IntSet>, segments IntSet) : void in class org.infinispan.stream.impl.CompletionRehashPublisherDecoratorTest |
From |
To |
|
Change Parameter Type kwcl : KeyWatchingCompletionListener to internalListener : Consumer<Supplier<PrimitiveIterator.OfInt>> in method package createDecorator(ch ConsistentHash, segmentsForOwner Set<Integer>, primarySegmentsForOwner Set<Integer>, internalListener Consumer<Supplier<PrimitiveIterator.OfInt>>, entryConsumer Consumer<Object>) : CompletionRehashPublisherDecorator<S> in class org.infinispan.stream.impl.CompletionRehashPublisherDecoratorTest |
From |
To |
|
Pull Up Attribute package lostSegments : Consumer<? super Supplier<PrimitiveIterator.OfInt>> from class org.infinispan.stream.impl.RehashPublisherDecorator to package lostSegments : Consumer<? super Supplier<PrimitiveIterator.OfInt>> from class org.infinispan.stream.impl.AbstractRehashPublisherDecorator |
From |
To |
|
Pull Up Attribute package localAddress : Address from class org.infinispan.stream.impl.RehashPublisherDecorator to package localAddress : Address from class org.infinispan.stream.impl.AbstractRehashPublisherDecorator |
From |
To |
|
Pull Up Attribute package keyConsumer : Consumer<Object> from class org.infinispan.stream.impl.RehashPublisherDecorator to package keyConsumer : Consumer<Object> from class org.infinispan.stream.impl.AbstractRehashPublisherDecorator |
From |
To |
|
Pull Up Attribute package iteratorOperation : AbstractCacheStream.IteratorOperation from class org.infinispan.stream.impl.RehashPublisherDecorator to package iteratorOperation : AbstractCacheStream.IteratorOperation from class org.infinispan.stream.impl.AbstractRehashPublisherDecorator |
From |
To |
|
Pull Up Attribute package dm : DistributionManager from class org.infinispan.stream.impl.RehashPublisherDecorator to package dm : DistributionManager from class org.infinispan.stream.impl.AbstractRehashPublisherDecorator |
From |
To |
|
Rename Parameter completionListener : KeyWatchingCompletionListener to userListener : Consumer<? super Supplier<PrimitiveIterator.OfInt>> in method package CompletionRehashPublisherDecorator(iteratorOperation AbstractCacheStream.IteratorOperation, dm DistributionManager, localAddress Address, userListener Consumer<? super Supplier<PrimitiveIterator.OfInt>>, completedSegments Consumer<? super Supplier<PrimitiveIterator.OfInt>>, lostSegments Consumer<? super Supplier<PrimitiveIterator.OfInt>>, keyConsumer Consumer<Object>) in class org.infinispan.stream.impl.CompletionRehashPublisherDecorator |
From |
To |
|
Rename Parameter kwcl : KeyWatchingCompletionListener to crpd : CompletionRehashPublisherDecorator<Object> in method package simpleAssert(resultingPublisher Publisher<Object>, valuePublisher PublishProcessor<Object>, segmentConsumer Consumer<Supplier<PrimitiveIterator.OfInt>>, crpd CompletionRehashPublisherDecorator<Object>, notifySegmentsCompleted Consumer<IntSet>, segments IntSet) : void in class org.infinispan.stream.impl.CompletionRehashPublisherDecoratorTest |
From |
To |
|
Rename Parameter kwcl : KeyWatchingCompletionListener to internalListener : Consumer<Supplier<PrimitiveIterator.OfInt>> in method package createDecorator(ch ConsistentHash, segmentsForOwner Set<Integer>, primarySegmentsForOwner Set<Integer>, internalListener Consumer<Supplier<PrimitiveIterator.OfInt>>, entryConsumer Consumer<Object>) : CompletionRehashPublisherDecorator<S> in class org.infinispan.stream.impl.CompletionRehashPublisherDecoratorTest |
From |
To |
|
Rename Parameter completionListener : Consumer<? super Supplier<PrimitiveIterator.OfInt>> to userListener : Consumer<? super Supplier<PrimitiveIterator.OfInt>> in method private CompletionListenerRehashIterator(intermediateOperations Iterable<IntermediateOperation>, userListener Consumer<? super Supplier<PrimitiveIterator.OfInt>>) in class org.infinispan.stream.impl.DistributedCacheStream.CompletionListenerRehashIterator |
From |
To |