From 2d66072d59a7b8e6264a8c7b3e1b858dece37960 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Thomas=20J=C3=A4ckle?= Date: Mon, 18 Dec 2023 20:07:22 +0100 Subject: [PATCH] #1844 fix wrong "reduction" when calculating retrieving `at-historical-revision` MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Thomas Jäckle --- .../utils/persistentactors/AbstractPersistenceActor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractPersistenceActor.java b/internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractPersistenceActor.java index a335bbb873..680027594c 100755 --- a/internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractPersistenceActor.java +++ b/internal/utils/persistent-actors/src/main/java/org/eclipse/ditto/internal/utils/persistentactors/AbstractPersistenceActor.java @@ -484,7 +484,7 @@ private void historicalRetrieveHandleLoadSnapshotResult(final C command, } }) .reduce((ewe1, ewe2) -> new EntityWithEvent( - eventStrategy.handle(ewe2.event, ewe2.entity, ewe2.revision), + eventStrategy.handle(ewe2.event, ewe1.entity, ewe2.revision), ewe2.event )) .runWith(Sink.foreach(entityWithEvent ->