Uses of Package
org.infinispan.reactive.publisher.impl
Package
Description
Commands that operate on the cache, either locally or remotely.
Factories are internal components used to create other components based on a cache's
configuration.
Cache
-specific notifications and eventing.-
ClassDescriptionEnumeration defining the possible delivery guarantees for entries.
-
ClassDescriptionManages distribution of various publisher operations that are ran locally and/or sent to remote nodes.Handles locally publishing entries from the cache.Handler for holding publisher results between requests of data
-
ClassDescriptionWrapper around an element returned that can either be a value or a segment completion.
-
ClassDescriptionManages distribution of various publisher operations that are ran locally and/or sent to remote nodes.ClusterPublisherManager that determines targets for the given segments and/or keys and then sends to local and remote nodes in parallel collecting results to be returned.Enumeration defining the possible delivery guarantees for entries.Handles locally publishing entries from the cache.This is the same as
SegmentPublisherSupplier
except that it also allows listening for when a segment is lost.Notification that can also contains lost segments.APublisher
that also notifies in a thread safe manner when a segment has sent all values upstream.Wrapper around an element returned that can either be a value or a segment completion. -
ClassDescriptionEnumeration defining the possible delivery guarantees for entries.
-
ClassDescriptionManages distribution of various publisher operations that are ran locally and/or sent to remote nodes.This is a special interface that can mark a Function so that a user can know if the actual value will change when the function is applied or not.