Uses of Interface
org.infinispan.reactive.publisher.impl.SegmentPublisherSupplier.Notification

Packages that use SegmentPublisherSupplier.Notification

Package	Description
org.infinispan.notifications.cachelistener	Cache-specific notifications and eventing.
org.infinispan.reactive.publisher.impl

Uses of SegmentPublisherSupplier.Notification in org.infinispan.notifications.cachelistener

Subinterfaces with type arguments of type SegmentPublisherSupplier.Notification in org.infinispan.notifications.cachelistener

Modifier and Type	Interface	Description
interface	QueueingSegmentListener<K, V, E extends Event<K,V>>	This interface describes methods needed for a segment listener that is used when iterating over the current events and be able to queue them properly

Methods in org.infinispan.notifications.cachelistener with parameters of type SegmentPublisherSupplier.Notification

Modifier and Type	Method	Description
org.reactivestreams.Publisher<CacheEntry<K,V>>	QueueingSegmentListener.apply(SegmentPublisherSupplier.Notification<CacheEntry<K,V>> cacheEntryNotification)	This should be invoked on a notification before actually processing the data.

Uses of SegmentPublisherSupplier.Notification in org.infinispan.reactive.publisher.impl

Subinterfaces of SegmentPublisherSupplier.Notification in org.infinispan.reactive.publisher.impl

Modifier and Type	Interface	Description
static interface	SegmentAwarePublisherSupplier.NotificationWithLost<R>	Notification that can also contains lost segments.

Methods in org.infinispan.reactive.publisher.impl that return types with arguments of type SegmentPublisherSupplier.Notification

Modifier and Type	Method	Description
org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>>	ClusterPublisherManager.entryPublisherForTopology(int topologyId, int batchSize, Map<Address,IntSet> targets)	This method is similar to ClusterPublisherManager.entryPublisher(IntSet, Set, InvocationContext, long, DeliveryGuarantee, int, Function) except it is designed to be used solely for iterating over entries for given targets with DeliveryGuarantee.AT_MOST_ONCE semantics since it cannot iterate using any other topology.
org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>>	ClusterPublisherManagerImpl.entryPublisherForTopology(int topologyId, int batchSize, Map<Address,IntSet> targets)
protected org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>>	ClusterPublisherManagerImpl.entryPublisherForTopology(int topologyId, int batchSize, Map<Address,IntSet> targets, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<CacheEntry<K,V>>> transformer)
org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>>	LocalClusterPublisherManagerImpl.entryPublisherForTopology(int topologyId, int batchSize, Map<Address,IntSet> targets)
org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<CacheEntry<K,V>>>	PartitionAwareClusterPublisherManager.entryPublisherForTopology(int topologyId, int batchSize, Map<Address,IntSet> targets)
org.reactivestreams.Publisher<SegmentPublisherSupplier.Notification<R>>	SegmentPublisherSupplier.publisherWithSegments()	A Publisher that will publish entries as originally configured from possibly remote sources.