Function processTransformResultAsync

src/pull.js:323–497

* Process transform result (async).

(result)

 * Process transform result (async).
 */
function processTransformResultAsync(result) {
    return __asyncGenerator(this, arguments, function processTransformResultAsync_1() {
        var resolved, batch, _a, result_2, result_2_1, item, _b, _c, _d, chunk, e_2_1, e_3_1, batch, _i, result_3, item, _e, _f, _g, chunk, e_4_1;
        var _h, e_3, _j, _k, _l, e_2, _m, _o, _p, e_4, _q, _r;
        return __generator(this, function (_s) {
            switch (_s.label) {
                case 0:
                    if (!(result instanceof Promise)) return [3 /*break*/, 5];
                    return [4 /*yield*/, __await(result)];
                case 1:
                    resolved = _s.sent();
                    return [5 /*yield**/, __values(__asyncDelegator(__asyncValues(processTransformResultAsync(resolved))))];
                case 2: return [4 /*yield*/, __await.apply(void 0, [_s.sent()])];
                case 3:
                    _s.sent();
                    return [4 /*yield*/, __await(void 0)];
                case 4: return [2 /*return*/, _s.sent()];
                case 5:
                    if (!(result === null)) return [3 /*break*/, 7];
                    return [4 /*yield*/, __await(void 0)];
                case 6: return [2 /*return*/, _s.sent()];
                case 7:
                    if (!(Array.isArray(result) && (result.length === 0 || result[0] instanceof Uint8Array))) return [3 /*break*/, 12];
                    if (!(result.length > 0)) return [3 /*break*/, 10];
                    return [4 /*yield*/, __await(result)];
                case 8: return [4 /*yield*/, _s.sent()];
                case 9:
                    _s.sent();
                    _s.label = 10;
                case 10: return [4 /*yield*/, __await(void 0)];
                case 11: return [2 /*return*/, _s.sent()];
                case 12:
                    if (!(0, from_js_1.isAsyncIterable)(result)) return [3 /*break*/, 40];
                    batch = [];
                    _s.label = 13;
                case 13:
                    _s.trys.push([13, 29, 30, 35]);
                    _a = true, result_2 = __asyncValues(result);
                    _s.label = 14;
                case 14: return [4 /*yield*/, __await(result_2.next())];
                case 15:
                    if (!(result_2_1 = _s.sent(), _h = result_2_1.done, !_h)) return [3 /*break*/, 28];
                    _k = result_2_1.value;
                    _a = false;
                    item = _k;
                    // Fast path: item is already Uint8Array
                    if (item instanceof Uint8Array) {
                        batch.push(item);
                        return [3 /*break*/, 27];
                    }
                    _s.label = 16;
                case 16:
                    _s.trys.push([16, 21, 22, 27]);
                    _b = true, _c = (e_2 = void 0, __asyncValues(flattenTransformYieldAsync(item)));
                    _s.label = 17;
                case 17: return [4 /*yield*/, __await(_c.next())];
                case 18:
                    if (!(_d = _s.sent(), _l = _d.done, !_l)) return [3 /*break*/, 20];