From 7937f0705dfab40945510e80a9cd2424b4069062 Mon Sep 17 00:00:00 2001
From: Andrii Plotnikov <plotnikovandrey1990@gmail.com>
Date: Sun, 28 Oct 2018 12:23:42 +0100
Subject: [PATCH] Fix logical mistake

---
 .../batch/processing/reactor/ReactorFileProcessor.java          | 2 +-
 1 file changed, 1 insertion(+), 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
index 68f03ac..3bee8b6 100644
--- 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