NonBlockingStore
@ThreadSafe @Deprecated public interface AdvancedCacheLoader<K,V> extends CacheLoader<K,V>
CacheLoader
interface that allows processing parallel iteration over the
existing entries.Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<MarshallableEntry<K,V>> |
entryPublisher(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata)
Deprecated.
Publishes all entries from this store.
|
default org.reactivestreams.Publisher<K> |
publishKeys(Predicate<? super K> filter)
Deprecated.
Publishes all the keys from this store.
|
int |
size()
Deprecated.
Returns the number of elements in the store.
|
contains, init, isAvailable, loadEntry
int size()
PersistenceException
- in case of an error, e.g. communicating with the external storagedefault org.reactivestreams.Publisher<K> publishKeys(Predicate<? super K> filter)
Subscriber
s as desired. Keys are not retrieved until a given Subscriber requests
them from the Subscription
.
Stores will return only non expired keys
filter
- a filter - null is treated as allowing all entriesorg.reactivestreams.Publisher<MarshallableEntry<K,V>> entryPublisher(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
Subscriber
s as desired. Entries are not retrieved until a given Subscriber requests
them from the Subscription
.
If fetchMetadata is true this store must guarantee to not return any expired entries.
filter
- a filter - null is treated as allowing all entriesfetchValue
- whether or not to fetch the value from the persistent store. E.g. if the iteration is
intended only over the key set, no point fetching the values from the persistent store as
wellfetchMetadata
- whether or not to fetch the metadata from the persistent store. E.g. if the iteration is
intended only ove the key set, then no point fetching the metadata from the persistent store
as wellCopyright © 2021 JBoss by Red Hat. All rights reserved.