Class ClusterPublisherManagerImpl.TopologySegmentAwarePublisherImpl

java.lang.Object

ClusterPublisherManagerImpl<K,V>.org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SegmentAwarePublisherImpl<CacheEntry<K,V>, CacheEntry<K,V>>

org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.TopologySegmentAwarePublisherImpl

All Implemented Interfaces:

SegmentPublisherSupplier<CacheEntry<K,V>>

Enclosing class:

ClusterPublisherManagerImpl<K,V>

protected class ClusterPublisherManagerImpl.TopologySegmentAwarePublisherImpl
extends ClusterPublisherManagerImpl<K,V>.SegmentAwarePublisherImpl<CacheEntry<K,V>, CacheEntry<K,V>>

Since:

10.0

Author:

wburns

Nested Class Summary

Nested classes/interfaces inherited from interface SegmentPublisherSupplier

SegmentPublisherSupplier.Notification<R>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TopologySegmentAwarePublisherImpl(int topologyId, int batchSize, Map<Address,IntSet> targets)
protected	TopologySegmentAwarePublisherImpl(int topologyId, int batchSize, Map<Address,IntSet> targets, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<CacheEntry<K,V>>> transformer)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<CacheEntry<K,V>>	publisherWithoutSegments()	Returns a publisher that can be used to subscribe to the values available.
org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>>	publisherWithSegments()	A Publisher that will publish entries as originally configured from possibly remote sources.

Methods inherited from class Object

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

Constructor Details

TopologySegmentAwarePublisherImpl

protected TopologySegmentAwarePublisherImpl(int topologyId,
 int batchSize,
 Map<Address,IntSet> targets)

TopologySegmentAwarePublisherImpl

protected TopologySegmentAwarePublisherImpl(int topologyId,
 int batchSize,
 Map<Address,IntSet> targets,
 Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<CacheEntry<K,V>>> transformer)

Method Details

publisherWithSegments

public org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>> publisherWithSegments()

Description copied from interface: SegmentPublisherSupplier

A Publisher that will publish entries as originally configured from possibly remote sources. The published items will be wrapped in a SegmentPublisherSupplier.Notification which can be either an item or segment completion notification. The type can be verified by first invoking SegmentPublisherSupplier.Notification.isValue() or SegmentPublisherSupplier.Notification.isSegmentComplete() after which the value or segment information should be retrieved. Note that each value will also have a segment attributed to it which can be access by invoking SegmentPublisherSupplier.Notification.valueSegment().

Note that segment completion can be interwoven with values and some segments may have no items present. However, once a segment complete notification is encountered for a given segment no additional values will be published to the same subscriber for the given segment.

If segment information is not required, please use SegmentPublisherSupplier.publisherWithoutSegments() as implementations may have additional optimizations in place for when this information is not required.

Specified by:

publisherWithSegments in interface SegmentPublisherSupplier<I>

Returns:

a Publisher that publishes the resulting values with segment information

publisherWithoutSegments

public org.reactivestreams.Publisher<CacheEntry<K,V>> publisherWithoutSegments()

Description copied from interface: SegmentPublisherSupplier

Returns a publisher that can be used to subscribe to the values available.

Specified by:

publisherWithoutSegments in interface SegmentPublisherSupplier<I>

Returns:

a Publisher that publishes the resulting values without corresponding segment information