Making the Subscribers use a common base class- fail the overall CF onError

Author: bbakerman

src/main/java/org/dataloader/DataLoaderHelper.java

@@ -746,6 +746,7 @@ public synchronized void onError(Throwable ex) {
                 // clear any cached view of this key because they all failed
                 dataLoader.clear(key);
             }
+            valuesFuture.completeExceptionally(ex);
         }
 
     }
@@ -763,7 +764,7 @@ private DataLoaderMapEntrySubscriber(
                 List<Object> callContexts,
                 List<CompletableFuture<V>> queuedFutures
         ) {
-            super(valuesFuture,keys,callContexts,queuedFutures);
+            super(valuesFuture, keys, callContexts, queuedFutures);
             this.callContextByKey = new HashMap<>();
             this.queuedFutureByKey = new HashMap<>();
             for (int idx = 0; idx < queuedFutures.size(); idx++) {
@@ -817,6 +818,8 @@ public synchronized void onError(Throwable ex) {
                     dataLoader.clear(key);
                 }
             }
+            valuesFuture.completeExceptionally(ex);
         }
+
     }
 }