From 2bd4b647985cc8068e9ccbeb4e727d872bf40998 Mon Sep 17 00:00:00 2001 From: fjtirado Date: Mon, 23 Mar 2026 15:32:12 +0100 Subject: [PATCH] [Fix #1261] Add scanAll test Signed-off-by: fjtirado --- .../persistence/test/AbstractHandlerPersistenceTest.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/impl/persistence/tests/src/main/java/io/serverlessworkflow/impl/persistence/test/AbstractHandlerPersistenceTest.java b/impl/persistence/tests/src/main/java/io/serverlessworkflow/impl/persistence/test/AbstractHandlerPersistenceTest.java index bd57fc59..9cdb9a75 100644 --- a/impl/persistence/tests/src/main/java/io/serverlessworkflow/impl/persistence/test/AbstractHandlerPersistenceTest.java +++ b/impl/persistence/tests/src/main/java/io/serverlessworkflow/impl/persistence/test/AbstractHandlerPersistenceTest.java @@ -39,6 +39,7 @@ import java.time.Instant; import java.util.Map; import java.util.Optional; +import java.util.stream.Stream; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; @@ -142,6 +143,9 @@ void testWorkflowInstance() throws InterruptedException { .writer() .taskCompleted(workflowContext, completedTaskContext(position2, completedMap)) .join(); + try (Stream stream = handlers.reader().scanAll(definition)) { + assertThat(stream.count()).isEqualTo(1); + } instance = (WorkflowPersistenceInstance) handlers.reader().find(definition, workflowInstance.id()).orElseThrow(); @@ -165,5 +169,8 @@ void testWorkflowInstance() throws InterruptedException { // workflow completed handlers.writer().completed(workflowContext).join(); assertThat(handlers.reader().find(definition, workflowInstance.id())).isEmpty(); + try (Stream stream = handlers.reader().scanAll(definition)) { + assertThat(stream.count()).isEqualTo(0); + } } }