Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.reactive.publisher.impl |
Modifier and Type | Method and Description |
---|---|
<K,I,R> InitialPublisherCommand<K,I,R> |
CommandsFactory.buildInitialPublisherCommand(String requestId,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
boolean trackKeys,
Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer) |
<K,I,R> InitialPublisherCommand<K,I,R> |
CommandsFactoryImpl.buildInitialPublisherCommand(String requestId,
DeliveryGuarantee deliveryGuarantee,
int batchSize,
IntSet segments,
Set<K> keys,
Set<K> excludedKeys,
boolean includeLoader,
boolean entryStream,
boolean trackKeys,
Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer) |
Modifier and Type | Method and Description |
---|---|
<I,R> CompletableFuture<PublisherResponse> |
PublisherHandler.register(InitialPublisherCommand<?,I,R> command)
Registers a publisher given the initial command arguments.
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.