Files F103826406

stream.js
No OneTemporary
Actions

Subscribers

None

File Metadata

Created: Tue, Mar 4, 23:42

stream.js
View Options

	"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;

Event Timeline