From e26ad676b3b261d0f9e636ce94c5b7bbc3c867ac Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Mon, 13 Oct 2025 15:46:34 +0200
Subject: [PATCH] dont read forever

---
 pkg/actor/state.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/pkg/actor/state.go b/pkg/actor/state.go
index 6303b30..be7c4ff 100644
--- a/pkg/actor/state.go
+++ b/pkg/actor/state.go
@@ -35,12 +35,15 @@ var ErrUnknownType = errors.New("unknown type")
 
 func (s *StateStorage) Load(r io.Reader, onMessage func(msg proto.Message)) error {
 	var err error
+	var evt *StorageEvent
 	for err == nil {
-		evt, err := s.Read(r)
+		evt, err = s.Read(r)
 		if err == nil {
 			onMessage(evt.Mutation)
 		}
-
+	}
+	if err == io.EOF {
+		return nil
 	}
 	return err
 }