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

Packages that use SegmentPublisherSupplier

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.cache.impl
org.infinispan.reactive.publisher.impl

Uses of SegmentPublisherSupplier in org.infinispan

Methods in org.infinispan that return SegmentPublisherSupplier

Modifier and Type	Method	Description
<R> SegmentPublisherSupplier<R>	CachePublisher.entryPublisher(Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache, resulting in multiple values.
<R> SegmentPublisherSupplier<R>	CachePublisher.entryPublisher(SerializableFunction<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)	Same as CachePublisher.entryPublisher(Function) except that the Function must also implement Serializable.
<R> SegmentPublisherSupplier<R>	CachePublisher.keyPublisher(Function<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)	Same as CachePublisher.entryPublisher(Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentPublisherSupplier<R>	CachePublisher.keyPublisher(SerializableFunction<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)	Same as CachePublisher.keyPublisher(Function) except that the Function must also implement Serializable.

Uses of SegmentPublisherSupplier in org.infinispan.cache.impl

Methods in org.infinispan.cache.impl that return SegmentPublisherSupplier

Modifier and Type	Method	Description
<R> SegmentPublisherSupplier<R>	CachePublisherImpl.entryPublisher(Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	CachePublisherImpl.entryPublisher(SerializableFunction<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	CachePublisherImpl.keyPublisher(Function<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	CachePublisherImpl.keyPublisher(SerializableFunction<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)

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

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

Modifier and Type	Interface	Description
interface	SegmentAwarePublisherSupplier<R>	This is the same as SegmentPublisherSupplier except that it also allows listening for when a segment is lost.

Methods in org.infinispan.reactive.publisher.impl that return SegmentPublisherSupplier

Modifier and Type	Method	Description
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache, resulting in multiple values.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)	Same as ClusterPublisherManager.entryPublisher(IntSet, Set, InvocationContext, long, DeliveryGuarantee, int, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)