Function processTransformResultSync

src/pull.js:285–319

* Process transform result (sync).

(result)

 * Process transform result (sync).
 */
function processTransformResultSync(result) {
    var batch, _i, result_1, item, _a, _b, chunk;
    return __generator(this, function (_c) {
        switch (_c.label) {
            case 0:
                if (result === null) {
                    return [2 /*return*/];
                }
                if (!(Array.isArray(result) && result.length > 0 && result[0] instanceof Uint8Array)) return [3 /*break*/, 3];
                if (!(result.length > 0)) return [3 /*break*/, 2];
                return [4 /*yield*/, result];
            case 1:
                _c.sent();
                _c.label = 2;
            case 2: return [2 /*return*/];
            case 3:
                if (!(0, from_js_1.isSyncIterable)(result)) return [3 /*break*/, 6];
                batch = [];
                for (_i = 0, result_1 = result; _i < result_1.length; _i++) {
                    item = result_1[_i];
                    for (_a = 0, _b = flattenTransformYieldSync(item); _a < _b.length; _a++) {
                        chunk = _b[_a];
                        batch.push(chunk);
                    }
                }
                if (!(batch.length > 0)) return [3 /*break*/, 5];
                return [4 /*yield*/, batch];
            case 4:
                _c.sent();
                _c.label = 5;
            case 5: return [2 /*return*/];
            case 6: throw new TypeError("Invalid transform result type");
        }
    });
}
/**
 * Process transform result (async).
 */