merging substream after flatMapMerge

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Mar 11, 2022 · 9ca056d · 9ca056d
1 parent f45549b
commit 9ca056d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java b/...eclipse/ditto/thingsearch/service/persistence/write/streaming/MongoSearchUpdaterFlow.java
@@ -112,8 +112,8 @@ public Flow<SubSource<AbstractWriteModel, NotUsed>, WriteResultAndErrors, NotUse
         return Flow.<SubSource<AbstractWriteModel, NotUsed>>create()
                 .flatMapConcat(source -> source.grouped(maxBulkSize)
                         .flatMapConcat(searchUpdateMapper::processWriteModels)
-                        .mergeSubstreams()
                         .flatMapMerge(parallelism, writeModels -> executeBulkWrite(shouldAcknowledge, writeModels))
+                        .mergeSubstreams()
                         .async(MongoSearchUpdaterFlow.DISPATCHER_NAME, parallelism)
                 );
     }