From dd13277195e8bf8221db690275f413207caa10e0 Mon Sep 17 00:00:00 2001 From: Michael Rose Date: Mon, 21 Jun 2021 14:49:31 +0200 Subject: [PATCH] add missing thenUnstashAll call (#30305) Add the missing `unstash` so that the next task would continue after a task successfully completed. --- .../java/jdocs/akka/persistence/typed/StashingExample.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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();