Fix logical mistake

aplotnikov · Oct 28, 2018 · 7937f07 · 7937f07
1 parent f7a9378
commit 7937f07
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/github/aplotnikov/batch/processing/reactor/ReactorFileProcessor.java b/src/main/java/io/github/aplotnikov/batch/processing/reactor/ReactorFileProcessor.java
@@ -19,7 +19,7 @@ class ReactorFileProcessor implements Runnable {
     @Override
     public void run() {
         Flux.merge(repository.readAll(), queue.poll())
-            .map(reader::read);
+            .flatMap(reader::read);
         // generate responses with pause
         // collect responses
         // generate result file