fix : issue with loading all data

rajadilipkolli · Dec 5, 2024 · 6337a58 · 6337a58
1 parent e011b6f
commit 6337a58
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/...ongodb-elasticsearch/src/main/java/com/example/mongoes/web/service/RestaurantService.java b/...ongodb-elasticsearch/src/main/java/com/example/mongoes/web/service/RestaurantService.java
@@ -62,18 +62,19 @@ public RestaurantService(
     }
 
     public Flux<Restaurant> loadData() {
-        return DataBufferUtils.read(
-                        new ClassPathResource("restaurants.json"),
-                        new DefaultDataBufferFactory(),
-                        4096)
+        return DataBufferUtils.join(
+                        DataBufferUtils.read(
+                                new ClassPathResource("restaurants.json"),
+                                new DefaultDataBufferFactory(),
+                                4096))
                 .map(
                         dataBuffer -> {
                             byte[] bytes = new byte[dataBuffer.readableByteCount()];
                             dataBuffer.read(bytes);
                             DataBufferUtils.release(dataBuffer);
                             return new String(bytes, StandardCharsets.UTF_8);
                         })
-                .flatMap(
+                .flatMapMany(
                         fileContent -> {
                             List<String> restaurantArray = Arrays.asList(fileContent.split("\n"));
                             return this.saveAll(restaurantArray);