FM / providers

/home/techb158/balavpn.abdallabala.com/node_modules/@nodelib/fs.walk/out/providers/

/home/techb158/balavpn.abdallabala.com/node_modules/@nodelib/fs.walk/out/providers

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

Edit: /home/techb158/balavpn.abdallabala.com/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;