From af3eb0d7bf1313a756fd773ea5caa990ff1366d1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mats=20T=C3=B6rnberg?= Date: Sun, 19 Oct 2025 16:46:14 +0200 Subject: [PATCH] fix close if no queue is used --- pkg/actor/disk_storage.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/actor/disk_storage.go b/pkg/actor/disk_storage.go index deff401..5dba330 100644 --- a/pkg/actor/disk_storage.go +++ b/pkg/actor/disk_storage.go @@ -104,7 +104,9 @@ func (s *DiskStorage[V]) LoadEvents(id uint64, grain Grain[V]) error { } func (s *DiskStorage[V]) Close() { - s.save() + if s.queue != nil { + s.save() + } close(s.done) }