renamed classes inline with their counterparts

Author: bbakerman

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

@@ -4,8 +4,8 @@
 import org.dataloader.annotations.Internal;
 import org.dataloader.impl.CompletableFutureKit;
 import org.dataloader.reactive.HelperIntegration;
-import org.dataloader.reactive.DataLoaderMapEntrySubscriber;
-import org.dataloader.reactive.DataLoaderSubscriber;
+import org.dataloader.reactive.MappedBatchSubscriber;
+import org.dataloader.reactive.BatchSubscriber;
 import org.dataloader.scheduler.BatchLoaderScheduler;
 import org.dataloader.stats.StatisticsCollector;
 import org.dataloader.stats.context.IncrementBatchLoadCountByStatisticsContext;
@@ -510,7 +510,7 @@ private CompletableFuture<List<V>> invokeMapBatchLoader(List<K> keys, BatchLoade
 
     private CompletableFuture<List<V>> invokeBatchPublisher(List<K> keys, List<Object> keyContexts, List<CompletableFuture<V>> queuedFutures, BatchLoaderEnvironment environment) {
         CompletableFuture<List<V>> loadResult = new CompletableFuture<>();
-        Subscriber<V> subscriber = new DataLoaderSubscriber<>(loadResult, keys, keyContexts, queuedFutures, helperIntegration());
+        Subscriber<V> subscriber = new BatchSubscriber<>(loadResult, keys, keyContexts, queuedFutures, helperIntegration());
 
         BatchLoaderScheduler batchLoaderScheduler = loaderOptions.getBatchLoaderScheduler();
         if (batchLoadFunction instanceof BatchPublisherWithContext) {
@@ -556,7 +556,7 @@ public void clearCacheEntriesOnExceptions(List<K> keys) {
 
     private CompletableFuture<List<V>> invokeMappedBatchPublisher(List<K> keys, List<Object> keyContexts, List<CompletableFuture<V>> queuedFutures, BatchLoaderEnvironment environment) {
         CompletableFuture<List<V>> loadResult = new CompletableFuture<>();
-        Subscriber<Map.Entry<K, V>> subscriber = new DataLoaderMapEntrySubscriber<>(loadResult, keys, keyContexts, queuedFutures, helperIntegration());
+        Subscriber<Map.Entry<K, V>> subscriber = new MappedBatchSubscriber<>(loadResult, keys, keyContexts, queuedFutures, helperIntegration());
 
         BatchLoaderScheduler batchLoaderScheduler = loaderOptions.getBatchLoaderScheduler();
         if (batchLoadFunction instanceof MappedBatchPublisherWithContext) {

src/main/java/org/dataloader/reactive/DataLoaderSubscriberBase.java renamed to src/main/java/org/dataloader/reactive/AbstractBatchSubscriber.java

@@ -18,7 +18,7 @@
  *
  * @param <T> for two
  */
-abstract class DataLoaderSubscriberBase<K, V, T> implements Subscriber<T> {
+abstract class AbstractBatchSubscriber<K, V, T> implements Subscriber<T> {
 
     final CompletableFuture<List<V>> valuesFuture;
     final List<K> keys;
@@ -31,7 +31,7 @@ abstract class DataLoaderSubscriberBase<K, V, T> implements Subscriber<T> {
     boolean onErrorCalled = false;
     boolean onCompleteCalled = false;
 
-    DataLoaderSubscriberBase(
+    AbstractBatchSubscriber(
             CompletableFuture<List<V>> valuesFuture,
             List<K> keys,
             List<Object> callContexts,

src/main/java/org/dataloader/reactive/DataLoaderSubscriber.java renamed to src/main/java/org/dataloader/reactive/BatchSubscriber.java

@@ -15,11 +15,11 @@
  * @param <K> the type of keys
  * @param <V> the type of values
  */
-public class DataLoaderSubscriber<K, V> extends DataLoaderSubscriberBase<K, V, V> {
+public class BatchSubscriber<K, V> extends AbstractBatchSubscriber<K, V, V> {
 
     private int idx = 0;
 
-    public DataLoaderSubscriber(
+    public BatchSubscriber(
             CompletableFuture<List<V>> valuesFuture,
             List<K> keys,
             List<Object> callContexts,

src/main/java/org/dataloader/reactive/DataLoaderMapEntrySubscriber.java renamed to src/main/java/org/dataloader/reactive/MappedBatchSubscriber.java

@@ -15,14 +15,14 @@
  * @param <K> the type of keys
  * @param <V> the type of values
  */
-public class DataLoaderMapEntrySubscriber<K, V> extends DataLoaderSubscriberBase<K, V, Map.Entry<K, V>> {
+public class MappedBatchSubscriber<K, V> extends AbstractBatchSubscriber<K, V, Map.Entry<K, V>> {
 
     private final Map<K, Object> callContextByKey;
     private final Map<K, List<CompletableFuture<V>>> queuedFuturesByKey;
     private final Map<K, V> completedValuesByKey = new HashMap<>();
 
 
-    public DataLoaderMapEntrySubscriber(
+    public MappedBatchSubscriber(
             CompletableFuture<List<V>> valuesFuture,
             List<K> keys,
             List<Object> callContexts,