async-later/src/to-async-iterable.js

"use strict";
exports.__esModule = true;
exports.toAsyncIterable = exports.asyncIterableFromObservable = void 0;
var tslib_1 = require("tslib");
var _1 = require(".");
function asyncIterableFromObservable(observable) {
    var _a = tslib_1.__read((0, _1.iterateLater)(), 3), iterable = _a[0], next = _a[1], complete = _a[2];
    observable.subscribe(next, function (error) { return next(Promise.reject(error)); }, complete);
    return iterable;
}
exports.asyncIterableFromObservable = asyncIterableFromObservable;
function _toAsyncIterable(value) {
    if (typeof value[Symbol.asyncIterator] === 'function')
        return value;
    if (typeof value.subscribe === 'function')
        return asyncIterableFromObservable(value);
    var iterate;
    if (typeof value[Symbol.iterator] === 'function') {
        iterate = function () {
            return tslib_1.__asyncGenerator(this, arguments, function () {
                var _a, _b, element, e_1_1;
                var e_1, _c;
                return tslib_1.__generator(this, function (_d) {
                    switch (_d.label) {
                        case 0:
                            _d.trys.push([0, 7, 8, 9]);
                            _a = tslib_1.__values(value), _b = _a.next();
                            _d.label = 1;
                        case 1:
                            if (!!_b.done) return [3 /*break*/, 6];
                            element = _b.value;
                            return [4 /*yield*/, tslib_1.__await(element)];
                        case 2: return [4 /*yield*/, tslib_1.__await.apply(void 0, [_d.sent()])];
                        case 3: return [4 /*yield*/, _d.sent()];
                        case 4:
                            _d.sent();
                            _d.label = 5;
                        case 5:
                            _b = _a.next();
                            return [3 /*break*/, 1];
                        case 6: return [3 /*break*/, 9];
                        case 7:
                            e_1_1 = _d.sent();
                            e_1 = { error: e_1_1 };
                            return [3 /*break*/, 9];
                        case 8:
                            try {
                                if (_b && !_b.done && (_c = _a["return"])) _c.call(_a);
                            }
                            finally { if (e_1) throw e_1.error; }
                            return [7 /*endfinally*/];
                        case 9: return [2 /*return*/];
                    }
                });
            });
        };
    }
    else {
        iterate = function () {
            return tslib_1.__asyncGenerator(this, arguments, function () {
                return tslib_1.__generator(this, function (_a) {
                    switch (_a.label) {
                        case 0: return [4 /*yield*/, tslib_1.__await(value)];
                        case 1: return [4 /*yield*/, tslib_1.__await.apply(void 0, [(_a.sent())])];
                        case 2: return [4 /*yield*/, _a.sent()];
                        case 3:
                            _a.sent();
                            return [2 /*return*/];
                    }
                });
            });
        };
    }
    return iterate();
}
function toAsyncIterable(value) {
    return typeof value === 'undefined'
        ? function (curriedValue) { return _toAsyncIterable(curriedValue); }
        : _toAsyncIterable(value);
}
exports.toAsyncIterable = toAsyncIterable;