Skip to content

Commit 7d2d916

Browse files
committed
fix: propagate errors occuring in cache._flush
1 parent 4bbb6e3 commit 7d2d916

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lib/state/cache.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,8 @@ export default class Cache {
125125
if (it.value && it.value.modified) {
126126
it.value.modified = false
127127
it.value.val = it.value.val.serialize()
128-
this._trie.put(Buffer.from(it.key, 'hex'), it.value.val, () => {
128+
this._trie.put(Buffer.from(it.key, 'hex'), it.value.val, (err: Error) => {
129+
if (err) return done(err)
129130
next = it.hasNext
130131
it.next()
131132
done()
@@ -134,7 +135,8 @@ export default class Cache {
134135
it.value.modified = false
135136
it.value.deleted = false
136137
it.value.val = new Account().serialize()
137-
this._trie.del(Buffer.from(it.key, 'hex'), () => {
138+
this._trie.del(Buffer.from(it.key, 'hex'), (err: Error) => {
139+
if (err) return done(err)
138140
next = it.hasNext
139141
it.next()
140142
done()

0 commit comments

Comments
 (0)