diff --git a/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/StashingExample.java b/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/StashingExample.java index 0ce82f1df6..5aab17bcd8 100644 --- a/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/StashingExample.java +++ b/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/StashingExample.java @@ -134,7 +134,9 @@ public interface StashingExample { private Effect onEndTask(State state, EndTask command) { if (state.taskIdInProgress.isPresent()) { if (state.taskIdInProgress.get().equals(command.taskId)) - return Effect().persist(new TaskCompleted(command.taskId)); + return Effect() + .persist(new TaskCompleted(command.taskId)) + .thenUnstashAll(); // continue with next task else return Effect().stash(); // other task in progress, wait with new task until later } else { return Effect().unhandled();