Replace Mono to Flux

aplotnikov · Nov 3, 2018 · b585aa4 · b585aa4
1 parent 8c21719
commit b585aa4
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main/java/io/github/aplotnikov/batch/processing/reactor/readers/XmlFileReader.java b/src/main/java/io/github/aplotnikov/batch/processing/reactor/readers/XmlFileReader.java
@@ -10,7 +10,6 @@
 import lombok.experimental.FieldDefaults;
 import net.jcip.annotations.NotThreadSafe;
 import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
 import reactor.core.publisher.SynchronousSink;
 import reactor.util.annotation.Nullable;
 
@@ -42,13 +41,13 @@ public final class XmlFileReader implements FileReader {
     public Flux<AbstractEvent> read(AbstractEvent event) {
         this.filePath = event.getSourcePath();
         return Flux.concat(
-                Mono.just(new FileProcessingStarted(filePath)),
+                Flux.just(new FileProcessingStarted(filePath)),
                 Flux.generate(
                         reader(filePath),
                         this::findClients,
                         closeReader()
                 ),
-                Mono.just(new FileProcessed(filePath))
+                Flux.just(new FileProcessed(filePath))
         );
     }