🔨refactor: Use mapConcat instead of flatMapConcat for flattening Option

lerna-stack · Feb 18, 2022 · ba4a77c · ba4a77c
1 parent 244f3d3
commit ba4a77c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/lerna/akka/entityreplication/raft/snapshot/sync/SnapshotSyncManager.scala b/src/main/scala/lerna/akka/entityreplication/raft/snapshot/sync/SnapshotSyncManager.scala
@@ -503,7 +503,7 @@ private[entityreplication] class SnapshotSyncManager(
           // prefer the latest term, index and offset
           Option(newEvent.mergeEntityIds(event))
       }
-      .flatMapConcat(e => Source(e.toSeq))
+      .mapConcat(identity) // flatten the `Option` element
       .flatMapConcat { event =>
         Source(event.entityIds)
           .mapAsync(settings.snapshotSyncCopyingParallelism) { entityId =>