Function applyStatefulSyncTransform

src/pull.js:529–556

* Apply a single stateful sync transform to a source.

(source, transform)

 * Apply a single stateful sync transform to a source.
 */
function applyStatefulSyncTransform(source, transform) {
    var output, _i, output_1, item, batch, _a, _b, chunk;
    return __generator(this, function (_c) {
        switch (_c.label) {
            case 0:
                output = transform(source);
                _i = 0, output_1 = output;
                _c.label = 1;
            case 1:
                if (!(_i < output_1.length)) return [3 /*break*/, 4];
                item = output_1[_i];
                batch = [];
                for (_a = 0, _b = flattenTransformYieldSync(item); _a < _b.length; _a++) {
                    chunk = _b[_a];
                    batch.push(chunk);
                }
                if (!(batch.length > 0)) return [3 /*break*/, 3];
                return [4 /*yield*/, batch];
            case 2:
                _c.sent();
                _c.label = 3;
            case 3:
                _i++;
                return [3 /*break*/, 1];
            case 4: return [2 /*return*/];
        }
    });
}
/**
 * Wrap sync source to add null flush signal at end.
 */