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
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.

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.

Uses of SegmentPublisherSupplier.Notification in org.infinispan.statetransfer

Methods in org.infinispan.statetransfer that return types with arguments of type SegmentPublisherSupplier.Notification

Modifier and Type	Method	Description
protected io.reactivex.rxjava3.core.Flowable<SegmentPublisherSupplier.Notification<InternalCacheEntry<?,?>>>	StateProviderImpl.readEntries(org.infinispan.commons.util.IntSet segments)

Method parameters in org.infinispan.statetransfer with type arguments of type SegmentPublisherSupplier.Notification

Modifier and Type	Method	Description
CompletionStage<Void>	OutboundTransferTask.execute(io.reactivex.rxjava3.core.Flowable<SegmentPublisherSupplier.Notification<InternalCacheEntry<?,?>>> notifications)	Starts sending entries from the data container and the first loader with fetch persistent data enabled to the target node.