diff --git a/src/stores/kvstore/KeyValueIndex.js b/src/stores/kvstore/KeyValueIndex.js index bf63a16..4ea3d7f 100644 --- a/src/stores/kvstore/KeyValueIndex.js +++ b/src/stores/kvstore/KeyValueIndex.js @@ -10,18 +10,17 @@ class KeyValueIndex { } updateIndex(oplog, updated) { - let handled = []; - - updated.reverse().forEach((item) => { + updated.reverse().reduce((handled, item) => { if(handled.indexOf(item.key) === -1) { handled.push(item.key); if(item.op === 'PUT') { this._index[item.key] = item.value - } else if (item.op === 'DEL') { + } else if(item.op === 'DEL') { delete this._index[item.key]; } } - }); + return handled; + }, []); } }