FM / providers

/home/techb158/balavpn.abdallabala.com/node_modules/fast-glob/out/providers/

/home/techb158/balavpn.abdallabala.com/node_modules/fast-glob/out/providers

Name	Size	Mode	Actions
filters/	-	0777	rm
matchers/	-	0777	rm
transformers/	-	0777	rm
async.d.ts	416	0666	edit dl rm
async.js	814	0666	edit dl rm
provider.d.ts	817	0666	edit dl rm
provider.js	2000	0666	edit dl rm
stream.d.ts	436	0666	edit dl rm
stream.js	1198	0666	edit dl rm
sync.d.ts	385	0666	edit dl rm
sync.js	779	0666	edit dl rm

Edit: /home/techb158/balavpn.abdallabala.com/node_modules/fast-glob/out/providers/stream.js (1198B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const stream_1 = require("stream");
const stream_2 = require("../readers/stream");
const provider_1 = require("./provider");
class ProviderStream extends provider_1.default {
    constructor() {
        super(...arguments);
        this._reader = new stream_2.default(this._settings);
    }
    read(task) {
        const root = this._getRootDirectory(task);
        const options = this._getReaderOptions(task);
        const source = this.api(root, task, options);
        const destination = new stream_1.Readable({ objectMode: true, read: () => { } });
        source
            .once('error', (error) => destination.emit('error', error))
            .on('data', (entry) => destination.emit('data', options.transform(entry)))
            .once('end', () => destination.emit('end'));
        destination
            .once('close', () => source.destroy());
        return destination;
    }
    api(root, task, options) {
        if (task.dynamic) {
            return this._reader.dynamic(root, options);
        }
        return this._reader.static(task.patterns, options);
    }
}
exports.default = ProviderStream;

cmd: