Function array

src/consumers.js:394–542

* Collect all chunks as an array from an async or sync source. * * @param source - Iterable or async iterable yielding Uint8Array[] batches * @param options - Optional signal and limit * @returns Promise resolving to array of Uint8Array chunks

(source, options)

 * @returns Promise resolving to array of Uint8Array chunks
 */
function array(source, options) {
    return __awaiter(this, void 0, void 0, function () {
        var signal, limit, chunks, batch, _i, batch_7, chunk, e_3_1, _a, source_7, batch, _b, batch_8, chunk, totalBytes, batch, _c, batch_9, chunk, e_4_1, _d, source_8, batch, _e, batch_10, chunk;
        var _f, source_9, source_9_1, _g, source_10, source_10_1;
        var _h, e_3, _j, _k, _l, e_4, _m, _o;
        var _p, _q, _r;
        return __generator(this, function (_s) {
            switch (_s.label) {
                case 0:
                    signal = options === null || options === void 0 ? void 0 : options.signal;
                    limit = options === null || options === void 0 ? void 0 : options.limit;
                    // Check for abort
                    if (signal === null || signal === void 0 ? void 0 : signal.aborted) {
                        throw (_p = signal.reason) !== null && _p !== void 0 ? _p : new DOMException('Aborted', 'AbortError');
                    }
                    chunks = [];
                    if (!(!signal && limit === undefined)) return [3 /*break*/, 15];
                    if (!(0, from_js_1.isAsyncIterable)(source)) return [3 /*break*/, 13];
                    _s.label = 1;
                case 1:
                    _s.trys.push([1, 6, 7, 12]);
                    _f = true, source_9 = __asyncValues(source);
                    _s.label = 2;
                case 2: return [4 /*yield*/, source_9.next()];
                case 3:
                    if (!(source_9_1 = _s.sent(), _h = source_9_1.done, !_h)) return [3 /*break*/, 5];
                    _k = source_9_1.value;
                    _f = false;
                    batch = _k;
                    for (_i = 0, batch_7 = batch; _i < batch_7.length; _i++) {
                        chunk = batch_7[_i];
                        chunks.push(chunk);
                    }
                    _s.label = 4;
                case 4:
                    _f = true;
                    return [3 /*break*/, 2];
                case 5: return [3 /*break*/, 12];
                case 6:
                    e_3_1 = _s.sent();
                    e_3 = { error: e_3_1 };
                    return [3 /*break*/, 12];
                case 7:
                    _s.trys.push([7, , 10, 11]);
                    if (!(!_f && !_h && (_j = source_9.return))) return [3 /*break*/, 9];
                    return [4 /*yield*/, _j.call(source_9)];
                case 8:
                    _s.sent();
                    _s.label = 9;
                case 9: return [3 /*break*/, 11];
                case 10:
                    if (e_3) throw e_3.error;
                    return [7 /*endfinally*/];
                case 11: return [7 /*endfinally*/];
                case 12: return [3 /*break*/, 14];
                case 13:
                    if ((0, from_js_1.isSyncIterable)(source)) {
                        for (_a = 0, source_7 = source; _a < source_7.length; _a++) {