diff --git a/ledis/ledis.go b/ledis/ledis.go index c28c29b..0bd4526 100644 --- a/ledis/ledis.go +++ b/ledis/ledis.go @@ -131,6 +131,8 @@ func (l *Ledis) flushAll() error { it := l.ldb.NewIterator() defer it.Close() + it.SeekToFirst() + w := l.ldb.NewWriteBatch() defer w.Rollback()