Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-10-07 22:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add amount and reverse iterator options to storage iterators

Browse Source
This commit is contained in:
haad 2024-02-16 16:58:06 +01:00
parent 16b3358355
commit 5a73b9cdfb
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/storage/composed.js
View File

@ -76,10 +76,11 @@ const ComposedStorage = async (storage1, storage2) => {
* @memberof module:Storage.Storage-Composed * @memberof module:Storage.Storage-Composed
* @instance * @instance
*/ */
const iterator = async function * () { const iterator = async function * ({ amount, reverse } = {}) {
const keys = [] const keys = []
const iteratorOptions = { amount: amount || -1, reverse: reverse || false }
for (const storage of [storage1, storage2]) { for (const storage of [storage1, storage2]) {
for await (const [key, value] of storage.iterator()) { for await (const [key, value] of storage.iterator(iteratorOptions)) {
if (!keys[key]) { if (!keys[key]) {
keys[key] = true keys[key] = true
yield [key, value] yield [key, value]

5
src/storage/level.js
View File

@ -78,8 +78,9 @@ const LevelStorage = async ({ path, valueEncoding } = {}) => {
* @memberof module:Storage.Storage-Level * @memberof module:Storage.Storage-Level
* @instance * @instance
*/ */
const iterator = async function * () { const iterator = async function * ({ amount, reverse } = {}) {
for await (const [key, value] of db.iterator()) { const iteratorOptions = { limit: amount || -1, reverse: reverse || false }
for await (const [key, value] of db.iterator(iteratorOptions)) {
yield [key, value] yield [key, value]
} }
} }