Removed comment

Signed-off-by: Peter Nied <[email protected]>
AndreKurait · Aug 20, 2024 · d036116 · d036116
1 parent baa7cf1
commit d036116
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/RFS/src/main/java/com/rfs/common/DocumentReindexer.java b/RFS/src/main/java/com/rfs/common/DocumentReindexer.java
@@ -45,12 +45,12 @@ Mono<Void> reindexDocsInParallelBatches(Flux<BulkDocSection> docs, String indexN
         var maxGroupsToPrefetch = 1;
 
         return bulkDocsBatches
-            .parallel(maxConcurrentWorkItems, maxConcurrentWorkItems /* ??? how is the related to the second arg on the next line ??? */)
+            .parallel(maxConcurrentWorkItems, maxConcurrentWorkItems)
             .runOn(scheduler, maxGroupsToPrefetch)
             .concatMapDelayError(docsGroup -> sendBulkRequest(UUID.randomUUID(), docsGroup, indexName, context))
             .doOnTerminate(scheduler::dispose)
             .then();
-        }
+    }
 
     Mono<Void> sendBulkRequest(UUID batchId, List<BulkDocSection> docsBatch, String indexName, IDocumentReindexContext context) {
         return client.sendBulkRequest(indexName, docsBatch, context.createBulkRequest()) // Send the request