fixing stream

BIBSYSDEV · Oct 30, 2023 · 13ad442 · 13ad442
1 parent 3b35b1c
commit 13ad442
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/batch-index/src/main/java/no/unit/nva/search/keybatch/KeyBasedBatchIndexHandler.java b/batch-index/src/main/java/no/unit/nva/search/keybatch/KeyBasedBatchIndexHandler.java
@@ -151,15 +151,13 @@ private void indexDocuments(List<IndexDocument> indexDocuments) {
         attempt(() -> indexBatch(indexDocuments)).orElse(this::logFailure);
     }
 
-    private Stream<BulkResponse> indexBatch(List<IndexDocument> indexDocuments) {
-        var bulkResponseStream = indexingClient.batchInsert(indexDocuments.stream());
-        bulkResponseStream.forEach(response -> logger.info("Bulk response: {}", response));
-        return bulkResponseStream;
+    private List<BulkResponse> logFailure(Failure<List<BulkResponse>> failure) {
+        logger.error("Bulk has failed: ", failure.getException());
+        return List.of();
     }
 
-    private Stream<BulkResponse> logFailure(Failure<Stream<BulkResponse>> failure) {
-        logger.error("Bulk has failed: ", failure.getException());
-        return null;
+    private List<BulkResponse> indexBatch(List<IndexDocument> indexDocuments) {
+        return indexingClient.batchInsert(indexDocuments.stream()).toList();
     }
 
     private boolean isValid(IndexDocument document) {