Class AdvancedAsyncCacheLoader<K,​V>

    • Method Detail

      • publishKeys

        public org.reactivestreams.Publisher<K> publishKeys​(Predicate<? super K> filter)
        Description copied from interface: AdvancedCacheLoader
        Publishes all the keys from this store. The given publisher can be used by as many Subscribers as desired. Keys are not retrieved until a given Subscriber requests them from the Subscription.

        Stores will return only non expired keys

        Specified by:
        publishKeys in interface AdvancedCacheLoader<K,​V>
        Parameters:
        filter - a filter
        Returns:
        a publisher that will provide the keys from the store
      • publishEntries

        public org.reactivestreams.Publisher<MarshalledEntry<K,​V>> publishEntries​(Predicate<? super K> filter,
                                                                                        boolean fetchValue,
                                                                                        boolean fetchMetadata)
        Description copied from interface: AdvancedCacheLoader
        Publishes all entries from this store. The given publisher can be used by as many Subscribers 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.

        Specified by:
        publishEntries in interface AdvancedCacheLoader<K,​V>
        Returns: