Function flattenTransformYieldAsync

src/pull.js:198–281

* Flatten transform yield to Uint8Array chunks (async).

(value)

 * Flatten transform yield to Uint8Array chunks (async).
 */
function flattenTransformYieldAsync(value) {
    return __asyncGenerator(this, arguments, function flattenTransformYieldAsync_1() {
        var _a, value_2, value_2_1, item, e_1_1, _i, value_3, item;
        var _b, e_1, _c, _d;
        return __generator(this, function (_e) {
            switch (_e.label) {
                case 0:
                    if (!(value instanceof Uint8Array)) return [3 /*break*/, 4];
                    return [4 /*yield*/, __await(value)];
                case 1: return [4 /*yield*/, _e.sent()];
                case 2:
                    _e.sent();
                    return [4 /*yield*/, __await(void 0)];
                case 3: return [2 /*return*/, _e.sent()];
                case 4:
                    if (!(typeof value === 'string')) return [3 /*break*/, 8];
                    return [4 /*yield*/, __await(encoder.encode(value))];
                case 5: return [4 /*yield*/, _e.sent()];
                case 6:
                    _e.sent();
                    return [4 /*yield*/, __await(void 0)];
                case 7: return [2 /*return*/, _e.sent()];
                case 8:
                    if (!(0, from_js_1.isAsyncIterable)(value)) return [3 /*break*/, 24];
                    _e.label = 9;
                case 9:
                    _e.trys.push([9, 16, 17, 22]);
                    _a = true, value_2 = __asyncValues(value);
                    _e.label = 10;
                case 10: return [4 /*yield*/, __await(value_2.next())];
                case 11:
                    if (!(value_2_1 = _e.sent(), _b = value_2_1.done, !_b)) return [3 /*break*/, 15];
                    _d = value_2_1.value;
                    _a = false;
                    item = _d;
                    return [5 /*yield**/, __values(__asyncDelegator(__asyncValues(flattenTransformYieldAsync(item))))];
                case 12: return [4 /*yield*/, __await.apply(void 0, [_e.sent()])];
                case 13:
                    _e.sent();
                    _e.label = 14;
                case 14:
                    _a = true;
                    return [3 /*break*/, 10];
                case 15: return [3 /*break*/, 22];
                case 16:
                    e_1_1 = _e.sent();
                    e_1 = { error: e_1_1 };
                    return [3 /*break*/, 22];
                case 17:
                    _e.trys.push([17, , 20, 21]);
                    if (!(!_a && !_b && (_c = value_2.return))) return [3 /*break*/, 19];
                    return [4 /*yield*/, __await(_c.call(value_2))];
                case 18:
                    _e.sent();
                    _e.label = 19;
                case 19: return [3 /*break*/, 21];
                case 20:
                    if (e_1) throw e_1.error;