| 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 processor_core_1 = __importDefault(require("./core/processor-core"));
|
| 7 | /**
|
| 8 | * A variation of Processor that can process a single DataEntity at a time.
|
| 9 | * This processor should have zero side-effects on the data.
|
| 10 | */
|
| 11 | class EachProcessor extends processor_core_1.default {
|
| 12 | /**
|
| 13 | * A generic method called by the Teraslice framework, calls {@link #forEach}
|
| 14 | * @param input an array of DataEntities
|
| 15 | * @returns an array of DataEntities
|
| 16 | */
|
| 17 | async handle(input) {
|
| 18 | input.forEach((data) => this.forEach(data));
|
| 19 | return input;
|
| 20 | }
|
| 21 | }
|
| 22 | exports.default = EachProcessor;
|
| 23 | //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZWFjaC1wcm9jZXNzb3IuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvb3BlcmF0aW9ucy9lYWNoLXByb2Nlc3Nvci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7OztBQUVBLDJFQUFrRDtBQUVsRDs7O0dBR0c7QUFFSCxNQUE4QixhQUE0QixTQUFRLHdCQUFnQjtJQU85RTs7OztNQUlFO0lBQ0YsS0FBSyxDQUFDLE1BQU0sQ0FBQyxLQUFtQjtRQUM1QixLQUFLLENBQUMsT0FBTyxDQUFDLENBQUMsSUFBSSxFQUFFLEVBQUUsQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7UUFDNUMsT0FBTyxLQUFLLENBQUM7SUFDakIsQ0FBQztDQUNKO0FBaEJELGdDQWdCQyJ9 |
| \ | No newline at end of file |