Class LocalAsyncCache.AsyncBulkCompleter<K,​V>

  • All Implemented Interfaces:
    java.util.function.BiConsumer<java.util.Map<K,​V>,​java.lang.Throwable>
    Enclosing interface:
    LocalAsyncCache<K,​V>

    public static final class LocalAsyncCache.AsyncBulkCompleter<K,​V>
    extends java.lang.Object
    implements java.util.function.BiConsumer<java.util.Map<K,​V>,​java.lang.Throwable>
    A function executed asynchronously after a bulk load completes.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private LocalCache<K,​java.util.concurrent.CompletableFuture<V>> cache  
      private java.util.Map<K,​java.util.concurrent.CompletableFuture<V>> proxies  
      private long startTime  
    • Constructor Summary

      Constructors 
      Constructor Description
      AsyncBulkCompleter​(LocalCache<K,​java.util.concurrent.CompletableFuture<V>> cache, java.util.Map<K,​java.util.concurrent.CompletableFuture<V>> proxies)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void accept​(@Nullable java.util.Map<K,​V> result, @Nullable java.lang.Throwable error)  
      private void addNewEntries​(java.util.Map<K,​V> result)
      Adds to the cache any extra entries computed that were not requested.
      private void fillProxies​(java.util.Map<K,​V> result)
      Populates the proxies with the computed result.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface java.util.function.BiConsumer

        andThen
    • Field Detail

      • cache

        private final LocalCache<K,​java.util.concurrent.CompletableFuture<V>> cache
      • proxies

        private final java.util.Map<K,​java.util.concurrent.CompletableFuture<V>> proxies
      • startTime

        private final long startTime
    • Constructor Detail

      • AsyncBulkCompleter

        AsyncBulkCompleter​(LocalCache<K,​java.util.concurrent.CompletableFuture<V>> cache,
                           java.util.Map<K,​java.util.concurrent.CompletableFuture<V>> proxies)
    • Method Detail

      • accept

        public void accept​(@Nullable java.util.Map<K,​V> result,
                           @Nullable java.lang.Throwable error)
        Specified by:
        accept in interface java.util.function.BiConsumer<K,​V>
      • fillProxies

        private void fillProxies​(java.util.Map<K,​V> result)
        Populates the proxies with the computed result.
      • addNewEntries

        private void addNewEntries​(java.util.Map<K,​V> result)
        Adds to the cache any extra entries computed that were not requested.