fix

Author: DanielBadura

src/Store/InMemoryStore.php

@@ -22,6 +22,7 @@
 use Patchlevel\EventSourcing\Store\Header\PlayheadHeader;
 use Patchlevel\EventSourcing\Store\Header\StreamNameHeader;
 
+use Throwable;
 use function array_filter;
 use function array_map;
 use function array_reverse;
@@ -94,7 +95,14 @@ public function save(Message ...$messages): void
      */
     public function transactional(Closure $function): void
     {
-        $function();
+        $messages = $this->messages;
+        try {
+            $function();
+        } catch (Throwable $e) {
+            $this->messages = $messages;
+
+            throw $e;
+        }
     }
 
     /** @return list<string> */
@@ -243,7 +251,7 @@ static function (Message $message) use ($criteria, $eventRegistry): bool {
                                 return false;
                             }
 
-                            if ($index < $criterion->fromIndex) {
+                            if ($index <= $criterion->fromIndex) {
                                 return false;
                             }
 

tests/Unit/Store/InMemoryStoreTest.php

@@ -163,7 +163,7 @@ public function testLoadFromIndex(): void
 
         $store = new InMemoryStore([$message1, $message2, $message3, $message4]);
 
-        $stream = $store->load(new Criteria(new FromIndexCriterion(3)));
+        $stream = $store->load(new Criteria(new FromIndexCriterion(2)));
 
         $messages = iterator_to_array($stream);