Sha256: 17cd9a5f28051d7ad6e391dfca9832a08d8ccb773bc9a8abc76d7e36e9d45bdb
Contents?: true
Size: 1.38 KB
Versions: 26
Compression:
Stored size: 1.38 KB
Contents
"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.build = void 0;
const fs_1 = __importDefault(require("fs"));
const readdirOpts = { withFileTypes: true };
const walkAsync = (state, directoryPath, currentDepth, callback) => {
state.queue.enqueue();
if (currentDepth < 0) {
state.queue.dequeue(null, state);
return;
}
state.counts.directories++;
// Perf: Node >= 10 introduced withFileTypes that helps us
// skip an extra fs.stat call.
fs_1.default.readdir(directoryPath || ".", readdirOpts, function process(error, entries = []) {
callback(entries, directoryPath, currentDepth);
state.queue.dequeue(state.options.suppressErrors ? null : error, state);
});
};
const walkSync = (state, directoryPath, currentDepth, callback) => {
if (currentDepth < 0) {
return;
}
state.counts.directories++;
let entries = [];
try {
entries = fs_1.default.readdirSync(directoryPath || ".", readdirOpts);
}
catch (e) {
if (!state.options.suppressErrors)
throw e;
}
callback(entries, directoryPath, currentDepth);
};
function build(isSynchronous) {
return isSynchronous ? walkSync : walkAsync;
}
exports.build = build;
Version data entries
26 entries across 26 versions & 1 rubygems