merkle-patricia-tree/dist/readStream.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.TrieReadStream = void 0;
const nibbles_1 = require("./util/nibbles");
const Readable = require('readable-stream').Readable;
class TrieReadStream extends Readable {
    constructor(trie) {
        super({ objectMode: true });
        this.trie = trie;
        this._started = false;
    }
    async _read() {
        if (this._started) {
            return;
        }
        this._started = true;
        try {
            await this.trie._findValueNodes(async (nodeRef, node, key, walkController) => {
                if (node !== null) {
                    this.push({
                        key: (0, nibbles_1.nibblesToBuffer)(key),
                        value: node.value,
                    });
                    walkController.allChildren(node, key);
                }
            });
        }
        catch (error) {
            if (error.message == 'Missing node in DB') {
                // pass
            }
            else {
                throw error;
            }
        }
        this.push(null);
    }
}
exports.TrieReadStream = TrieReadStream;
//# sourceMappingURL=readStream.js.map