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<R>>	SegmentPublisherSupplier.publisherWithSegments()	A Publisher that will publish entries as originally configured from possibly remote sources.