mirror of
https://github.com/joelwmale/webhook-action.git
synced 2024-11-30 03:15:24 +01:00
31 lines
936 B
JavaScript
31 lines
936 B
JavaScript
|
"use strict";
|
||
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||
|
|
const async_1 = require("../readers/async");
|
||
|
|
class AsyncProvider {
|
||
|
|
constructor(_root, _settings) {
|
||
|
|
this._root = _root;
|
||
|
|
this._settings = _settings;
|
||
|
|
this._reader = new async_1.default(this._root, this._settings);
|
||
|
|
this._storage = new Set();
|
||
|
|
}
|
||
|
|
read(callback) {
|
||
|
|
this._reader.onError((error) => {
|
||
|
|
callFailureCallback(callback, error);
|
||
|
|
});
|
||
|
|
this._reader.onEntry((entry) => {
|
||
|
|
this._storage.add(entry);
|
||
|
|
});
|
||
|
|
this._reader.onEnd(() => {
|
||
|
|
callSuccessCallback(callback, [...this._storage]);
|
||
|
|
});
|
||
|
|
this._reader.read();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
exports.default = AsyncProvider;
|
||
|
|
function callFailureCallback(callback, error) {
|
||
|
|
callback(error);
|
||
|
|
}
|
||
|
|
function callSuccessCallback(callback, entries) {
|
||
|
|
callback(null, entries);
|
||
|
|
}
|