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

Class KeyPublisherResult<K,R>

java.lang.Object

org.infinispan.reactive.publisher.impl.commands.reduction.KeyPublisherResult<K,R>

All Implemented Interfaces:

PublisherResult<R>

public class KeyPublisherResult<K,R>
extends Object
implements PublisherResult<R>

A PublisherResult that was performed due to included keys. Note that this response is only ever created on the originator node. This is because we can't have a partial response with key based publishers. Either all results are returned or the node crashes or has an exception.

Since:

10.0

Author:

wburns

Constructor Summary

Constructors

Constructor and Description
KeyPublisherResult(Set<K> suspectedKeys)

Method Summary

Modifier and Type	Method and Description
R	getResult()
Set<K>	getSuspectedKeys()
IntSet	getSuspectedSegments()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KeyPublisherResult

public KeyPublisherResult(Set<K> suspectedKeys)

Method Detail

getSuspectedSegments

public IntSet getSuspectedSegments()

Specified by:

getSuspectedSegments in interface PublisherResult<R>

getSuspectedKeys

public Set<K> getSuspectedKeys()

Specified by:

getSuspectedKeys in interface PublisherResult<R>

getResult

public R getResult()

Specified by:

getResult in interface PublisherResult<R>

toString

public String toString()

Overrides:

toString in class Object