Fix "Head of empty stream" error in EnforcementFlow.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
eclipse-ditto · Mar 17, 2022 · f8a21c5 · f8a21c5
1 parent f6f26a3
commit f8a21c5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...va/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java b/...va/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java
@@ -180,8 +180,9 @@ public <T> SubSource<AbstractWriteModel, T> create(
                                 searchUpdateObserver.process(changedMetadata, thing);
                                 return computeWriteModel(changedMetadata, thing);
                             })
-                            .runWith(Sink.head(), system);
-                });
+                            .runWith(Sink.seq(), system);
+                })
+                .mapConcat(writeModels -> writeModels);
     }
 
     private Source<Pair<ThingId, JsonObject>, NotUsed> retrieveThingFromCachingFacade(final ThingId thingId,