Uses of Interface
org.infinispan.reactive.publisher.impl.commands.reduction.PublisherResult

Packages that use PublisherResult

Package	Description
org.infinispan.reactive.publisher.impl
org.infinispan.reactive.publisher.impl.commands.reduction

Uses of PublisherResult in org.infinispan.reactive.publisher.impl

Methods in org.infinispan.reactive.publisher.impl that return types with arguments of type PublisherResult

Modifier and Type	Method and Description
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) Performs the given transformer and finalizer on data in the cache that is local, resulting in a single value.
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
protected <R> CompletionStage<PublisherResult<R>>	LocalPublisherManagerImpl.exactlyOnceHandleLostSegments(CompletionStage<R> finalValue, org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener)
protected <R> CompletionStage<PublisherResult<R>>	NonSegmentedLocalPublisherManagerImpl.exactlyOnceHandleLostSegments(CompletionStage<R> finalValue, org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener listener)
protected <R> CompletionStage<PublisherResult<R>>	LocalPublisherManagerImpl.handleLostSegments(CompletionStage<R> stage, org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.SegmentListener segmentListener)
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) Same as LocalPublisherManager.entryReduction(boolean, IntSet, Set, Set, boolean, DeliveryGuarantee, Function, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> CompletionStage<PublisherResult<R>>	LocalPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, Set<K> keysToExclude, boolean includeLoader, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> collator, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Uses of PublisherResult in org.infinispan.reactive.publisher.impl.commands.reduction

Classes in org.infinispan.reactive.publisher.impl.commands.reduction that implement PublisherResult

Modifier and Type	Class and Description
class	KeyPublisherResult<K,R> A PublisherResult that was performed due to included keys.
class	SegmentPublisherResult<R> A PublisherResult that was performed due to segments only