Compare commits
2 Commits
a0c82dc351
...
86f97f2888
| 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