Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
Modifier and Type | Method and Description |
---|---|
<K,V,R> ReductionPublisherRequestCommand<K> |
CommandsFactory.buildEntryReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
<K,V,R> ReductionPublisherRequestCommand<K> |
CommandsFactoryImpl.buildEntryReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
<K,R> ReductionPublisherRequestCommand<K> |
CommandsFactory.buildKeyReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
<K,R> ReductionPublisherRequestCommand<K> |
CommandsFactoryImpl.buildKeyReductionPublisherCommand(boolean parallelStream,
DeliveryGuarantee deliveryGuarantee,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.