[Fix #1261] Add scanAll test (#1262)

Signed-off-by: fjtirado <ftirados@redhat.com>

Author: fjtirado

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<WorkflowInstance> 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<WorkflowInstance> stream = handlers.reader().scanAll(definition)) {
+      assertThat(stream.count()).isEqualTo(0);
+    }
   }
 }