| 1 | ;
|
| 2 | var __importDefault = (this && this.__importDefault) || function (mod) {
|
| 3 | return (mod && mod.__esModule) ? mod : { "default": mod };
|
| 4 | };
|
| 5 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 6 | const utils_1 = require("@terascope/utils");
|
| 7 | const processor_core_1 = __importDefault(require("./core/processor-core"));
|
| 8 | /**
|
| 9 | * A variation of "Processor" that can handle a batch of data at a time.
|
| 10 | */
|
| 11 | class BatchProcessor extends processor_core_1.default {
|
| 12 | async handle(input) {
|
| 13 | const output = await this.onBatch(utils_1.DataEntity.makeArray(input));
|
| 14 | return utils_1.DataEntity.makeArray(output);
|
| 15 | }
|
| 16 | }
|
| 17 | exports.default = BatchProcessor;
|
| 18 | //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiYmF0Y2gtcHJvY2Vzc29yLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL29wZXJhdGlvbnMvYmF0Y2gtcHJvY2Vzc29yLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsNENBQThDO0FBRTlDLDJFQUFrRDtBQUVsRDs7R0FFRztBQUVILE1BQThCLGNBQTZCLFNBQVEsd0JBQWdCO0lBTy9FLEtBQUssQ0FBQyxNQUFNLENBQUMsS0FBbUI7UUFDNUIsTUFBTSxNQUFNLEdBQUcsTUFBTSxJQUFJLENBQUMsT0FBTyxDQUFDLGtCQUFVLENBQUMsU0FBUyxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUM7UUFDL0QsT0FBTyxrQkFBVSxDQUFDLFNBQVMsQ0FBQyxNQUFNLENBQUMsQ0FBQztJQUN4QyxDQUFDO0NBQ0o7QUFYRCxpQ0FXQyJ9 |
| \ | No newline at end of file |