File manager - Edit - /usr/local/lib/node_modules/ghost-cli/node_modules/rxjs/dist/esm5/internal/operators/onErrorResumeNext.js
Back
import { __read, __spreadArray } from "tslib"; import { operate } from '../util/lift'; import { innerFrom } from '../observable/from'; import { argsOrArgArray } from '../util/argsOrArgArray'; import { OperatorSubscriber } from './OperatorSubscriber'; import { noop } from '../util/noop'; export function onErrorResumeNext() { var sources = []; for (var _i = 0; _i < arguments.length; _i++) { sources[_i] = arguments[_i]; } var nextSources = argsOrArgArray(sources); return operate(function (source, subscriber) { var remaining = __spreadArray([source], __read(nextSources)); var subscribeNext = function () { if (!subscriber.closed) { if (remaining.length > 0) { var nextSource = void 0; try { nextSource = innerFrom(remaining.shift()); } catch (err) { subscribeNext(); return; } var innerSub = new OperatorSubscriber(subscriber, undefined, noop, noop); subscriber.add(nextSource.subscribe(innerSub)); innerSub.add(subscribeNext); } else { subscriber.complete(); } } }; subscribeNext(); }); } //# sourceMappingURL=onErrorResumeNext.js.map
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings