FM / providers

/var/www/flurhymez/node_modules/@nodelib/fs.walk/out/providers/

/var/www/flurhymez/node_modules/@nodelib/fs.walk/out/providers

Name	Size	Mode	Actions
async.d.ts	478	0644	edit dl rm
async.js	895	0644	edit dl rm
index.d.ts	167	0644	edit dl rm
index.js	388	0644	edit dl rm
stream.d.ts	413	0644	edit dl rm
stream.js	1021	0644	edit dl rm
sync.d.ts	338	0644	edit dl rm
sync.js	407	0644	edit dl rm

Edit: /var/www/flurhymez/node_modules/@nodelib/fs.walk/out/providers/stream.js (1021B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const stream_1 = require("stream");
const async_1 = require("../readers/async");
class StreamProvider {
    constructor(_root, _settings) {
        this._root = _root;
        this._settings = _settings;
        this._reader = new async_1.default(this._root, this._settings);
        this._stream = new stream_1.Readable({
            objectMode: true,
            read: () => { },
            destroy: () => {
                if (!this._reader.isDestroyed) {
                    this._reader.destroy();
                }
            }
        });
    }
    read() {
        this._reader.onError((error) => {
            this._stream.emit('error', error);
        });
        this._reader.onEntry((entry) => {
            this._stream.push(entry);
        });
        this._reader.onEnd(() => {
            this._stream.push(null);
        });
        this._reader.read();
        return this._stream;
    }
}
exports.default = StreamProvider;

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); const stream_1 = require("stream"); const async_1 = require("../readers/async"); class StreamProvider { constructor(_root, _settings) { this._root = _root; this._settings = _settings; this._reader = new async_1.default(this._root, this._settings); this._stream = new stream_1.Readable({ objectMode: true, read: () => { }, destroy: () => { if (!this._reader.isDestroyed) { this._reader.destroy(); } } }); } read() { this._reader.onError((error) => { this._stream.emit('error', error); }); this._reader.onEntry((entry) => { this._stream.push(entry); }); this._reader.onEnd(() => { this._stream.push(null); }); this._reader.read(); return this._stream; } } exports.default = StreamProvider;