FM / providers

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

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

Name	Size	Mode	Actions
async.d.ts	513	0644	edit dl rm
async.d.ts.map	578	0644	edit dl rm
async.js	936	0644	edit dl rm
async.spec.d.ts	52	0644	edit dl rm
async.spec.d.ts.map	127	0644	edit dl rm
async.spec.js	1789	0644	edit dl rm
index.d.ts	206	0644	edit dl rm
index.d.ts.map	259	0644	edit dl rm
index.js	397	0644	edit dl rm
stream.d.ts	456	0644	edit dl rm
stream.d.ts.map	480	0644	edit dl rm
stream.js	1055	0644	edit dl rm
stream.spec.d.ts	53	0644	edit dl rm
stream.spec.d.ts.map	129	0644	edit dl rm
stream.spec.js	2651	0644	edit dl rm
sync.d.ts	372	0644	edit dl rm
sync.d.ts.map	432	0644	edit dl rm
sync.js	421	0644	edit dl rm
sync.spec.d.ts	51	0644	edit dl rm
sync.spec.d.ts.map	125	0644	edit dl rm
sync.spec.js	1017	0644	edit dl rm

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

"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;