Gecko [ c.stage.kornherr.net ]

Linux v69820.1blu.de 4.15.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64
Apache/2.4.58
Server IP : 195.90.215.149 & Your IP : 216.73.217.80
Domains : Cant Read [ /etc/named.conf ]
User : www-data

Name	Size	Permission	Date
async.d.ts	473 B	-rw-r--r--	2024-03-21 05:18
async.js	1.18 KB	-rw-r--r--	2024-03-21 05:18
reader.d.ts	714 B	-rw-r--r--	2024-03-21 05:18
reader.js	1.04 KB	-rw-r--r--	2024-03-21 05:18
stream.d.ts	566 B	-rw-r--r--	2024-03-21 05:18
stream.js	1.83 KB	-rw-r--r--	2024-03-21 05:18
sync.d.ts	506 B	-rw-r--r--	2024-03-21 05:18
sync.js	1.3 KB	-rw-r--r--	2024-03-21 05:18

Rename

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const fsWalk = require("@nodelib/fs.walk");
const reader_1 = require("./reader");
const stream_1 = require("./stream");
class ReaderAsync extends reader_1.default {
    constructor() {
        super(...arguments);
        this._walkAsync = fsWalk.walk;
        this._readerStream = new stream_1.default(this._settings);
    }
    dynamic(root, options) {
        return new Promise((resolve, reject) => {
            this._walkAsync(root, options, (error, entries) => {
                if (error === null) {
                    resolve(entries);
                }
                else {
                    reject(error);
                }
            });
        });
    }
    async static(patterns, options) {
        const entries = [];
        const stream = this._readerStream.static(patterns, options);
        // After #235, replace it with an asynchronous iterator.
        return new Promise((resolve, reject) => {
            stream.once('error', reject);
            stream.on('data', (entry) => entries.push(entry));
            stream.once('end', () => resolve(entries));
        });
    }
}
exports.default = ReaderAsync;