Files F104222395

stream.js
No OneTemporary
Actions

Subscribers

None

File Metadata

Created: Fri, Mar 7, 09:36

stream.js
View Options

	"use strict";
	Object.defineProperty(exports, "__esModule", { value: true });
	const stream_1 = require("stream");
	const fsStat = require("@nodelib/fs.stat");
	const fsWalk = require("@nodelib/fs.walk");
	const reader_1 = require("./reader");
	class ReaderStream extends reader_1.default {
	constructor() {
	super(...arguments);
	this._walkStream = fsWalk.walkStream;
	this._stat = fsStat.stat;
	}
	dynamic(root, options) {
	return this._walkStream(root, options);
	}
	static(patterns, options) {
	const filepaths = patterns.map(this._getFullEntryPath, this);
	const stream = new stream_1.PassThrough({ objectMode: true });
	stream._write = (index, _enc, done) => {
	return this._getEntry(filepaths[index], patterns[index], options)
	.then((entry) => {
	if (entry !== null && options.entryFilter(entry)) {
	stream.push(entry);
	}
	if (index === filepaths.length - 1) {
	stream.end();
	}
	done();
	})
	.catch(done);
	};
	for (let i = 0; i < filepaths.length; i++) {
	stream.write(i);
	}
	return stream;
	}
	_getEntry(filepath, pattern, options) {
	return this._getStat(filepath)
	.then((stats) => this._makeEntry(stats, pattern))
	.catch((error) => {
	if (options.errorFilter(error)) {
	return null;
	}
	throw error;
	});
	}
	_getStat(filepath) {
	return new Promise((resolve, reject) => {
	this._stat(filepath, this._fsStatSettings, (error, stats) => {
	return error === null ? resolve(stats) : reject(error);
	});
	});
	}
	}
	exports.default = ReaderStream;

Event Timeline