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() {
|
func (s *DiskStorage[V]) Close() {
|
||||||
s.save()
|
if s.queue != nil {
|
||||||
|
s.save()
|
||||||
|
}
|
||||||
close(s.done)
|
close(s.done)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user