Package | Description |
---|---|
org.infinispan.reactive.publisher.impl | |
org.infinispan.reactive.publisher.impl.commands.batch |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<PublisherResponse> |
PublisherHandler.getNext(String requestId)
Retrieves the next response for the same request id that was configured on the command when invoking
PublisherHandler.register(InitialPublisherCommand) . |
<I,R> CompletableFuture<PublisherResponse> |
PublisherHandler.register(InitialPublisherCommand<?,I,R> command)
Registers a publisher given the initial command arguments.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyPublisherResponse
A Publisher Response that is used when key tracking is enabled.
|
Modifier and Type | Method and Description |
---|---|
static PublisherResponse |
PublisherResponse.emptyResponse(IntSet completedSegments,
IntSet lostSegments) |
PublisherResponse |
PublisherResponseExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends PublisherResponse>> |
PublisherResponseExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
PublisherResponseExternalizer.writeObject(ObjectOutput output,
PublisherResponse object) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.