fix compile errors

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Aug 22, 2022 · 6e8561b · 6e8561b
1 parent 0966597
commit 6e8561b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...n/java/org/eclipse/ditto/internal/utils/persistence/mongo/streaming/MongoReadJournal.java b/...n/java/org/eclipse/ditto/internal/utils/persistence/mongo/streaming/MongoReadJournal.java
@@ -288,9 +288,9 @@ public Source<String, NotUsed> getJournalPidsWithTag(final String tag,
                         .grouped(batchSize)
                         .flatMapConcat(pids -> {
                             if (considerOnlyLatest) {
-                                return filterPidsThatDoesntContainTagInNewestEntry(journal, pids, tag)
+                                return filterPidsThatDoesntContainTagInNewestEntry(journal, pids, tag);
                             } else {
-                                return pids;
+                                return Source.from(pids);
                             }
                         }));
     }