Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
86f97f2888 | ||
|
|
af3eb0d7bf |
@@ -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)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user