Class LocalAsyncLoadingCache.AsyncBulkCompleter

  • All Implemented Interfaces:
    java.util.function.BiConsumer<java.util.Map<K,​V>,​java.lang.Throwable>
    Enclosing class:
    LocalAsyncLoadingCache<C extends LocalCache<K,​java.util.concurrent.CompletableFuture<V>>,​K,​V>

    private final class LocalAsyncLoadingCache.AsyncBulkCompleter
    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 java.util.Map<K,​java.util.concurrent.CompletableFuture<V>> proxies  
      private long startTime  
    • Constructor Summary

      Constructors 
      Constructor Description
      AsyncBulkCompleter​(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​(java.util.Map<K,​V> result, 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

      • proxies

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

        private final long startTime
    • Constructor Detail

      • AsyncBulkCompleter

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

      • accept

        public void accept​(java.util.Map<K,​V> result,
                           java.lang.Throwable error)
        Specified by:
        accept in interface java.util.function.BiConsumer<java.util.Map<K,​V>,​java.lang.Throwable>
      • 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.