Package | Description |
---|---|
org.infinispan.reactive.publisher.impl |
Modifier and Type | Method and Description |
---|---|
<R> SegmentAwarePublisher<R> |
LocalPublisherManager.entryPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
Performs the given transformer on data in the cache that is local, resulting in a stream of values of
possibly varying size.
|
<R> SegmentAwarePublisher<R> |
LocalPublisherManagerImpl.entryPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer) |
<R> SegmentAwarePublisher<R> |
LocalPublisherManager.keyPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
Same as
LocalPublisherManager.entryPublisher(IntSet, Set, Set, boolean, DeliveryGuarantee, Function)
except that the source publisher provided to the transformer is made up of keys only. |
<R> SegmentAwarePublisher<R> |
LocalPublisherManagerImpl.keyPublisher(IntSet segments,
Set<K> keysToInclude,
Set<K> keysToExclude,
boolean includeLoader,
DeliveryGuarantee deliveryGuarantee,
Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.