projects
/
dotfiles
/
.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Giant blob of minor changes
[dotfiles/.git]
/
.config
/
coc
/
extensions
/
node_modules
/
coc-prettier
/
node_modules
/
rxjs
/
_esm5
/
internal
/
operators
/
onErrorResumeNext.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/onErrorResumeNext.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/onErrorResumeNext.js
index acf162882b9e3f8e321cabac94fea4e20c1cc7d3..898fa3def0c818d6d1aae7fd6e04e165ecca25d6 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/onErrorResumeNext.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/onErrorResumeNext.js
@@
-1,10
+1,8
@@
-/** PURE_IMPORTS_START tslib,_observable_from,_util_isArray,_
OuterSubscriber,_InnerSubscriber,_util_subscribeToResult
PURE_IMPORTS_END */
+/** PURE_IMPORTS_START tslib,_observable_from,_util_isArray,_
innerSubscribe
PURE_IMPORTS_END */
import * as tslib_1 from "tslib";
import { from } from '../observable/from';
import { isArray } from '../util/isArray';
import * as tslib_1 from "tslib";
import { from } from '../observable/from';
import { isArray } from '../util/isArray';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe';
export function onErrorResumeNext() {
var nextSources = [];
for (var _i = 0; _i < arguments.length; _i++) {
export function onErrorResumeNext() {
var nextSources = [];
for (var _i = 0; _i < arguments.length; _i++) {
@@
-20,12
+18,12
@@
export function onErrorResumeNextStatic() {
for (var _i = 0; _i < arguments.length; _i++) {
nextSources[_i] = arguments[_i];
}
for (var _i = 0; _i < arguments.length; _i++) {
nextSources[_i] = arguments[_i];
}
- var source =
null
;
+ var source =
undefined
;
if (nextSources.length === 1 && isArray(nextSources[0])) {
nextSources = nextSources[0];
}
source = nextSources.shift();
if (nextSources.length === 1 && isArray(nextSources[0])) {
nextSources = nextSources[0];
}
source = nextSources.shift();
- return from(source
, null
).lift(new OnErrorResumeNextOperator(nextSources));
+ return from(source).lift(new OnErrorResumeNextOperator(nextSources));
}
var OnErrorResumeNextOperator = /*@__PURE__*/ (function () {
function OnErrorResumeNextOperator(nextSources) {
}
var OnErrorResumeNextOperator = /*@__PURE__*/ (function () {
function OnErrorResumeNextOperator(nextSources) {
@@
-44,10
+42,10
@@
var OnErrorResumeNextSubscriber = /*@__PURE__*/ (function (_super) {
_this.nextSources = nextSources;
return _this;
}
_this.nextSources = nextSources;
return _this;
}
- OnErrorResumeNextSubscriber.prototype.notifyError = function (
error, innerSub
) {
+ OnErrorResumeNextSubscriber.prototype.notifyError = function () {
this.subscribeToNextSource();
};
this.subscribeToNextSource();
};
- OnErrorResumeNextSubscriber.prototype.notifyComplete = function (
innerSub
) {
+ OnErrorResumeNextSubscriber.prototype.notifyComplete = function () {
this.subscribeToNextSource();
};
OnErrorResumeNextSubscriber.prototype._error = function (err) {
this.subscribeToNextSource();
};
OnErrorResumeNextSubscriber.prototype._error = function (err) {
@@
-61,10
+59,10
@@
var OnErrorResumeNextSubscriber = /*@__PURE__*/ (function (_super) {
OnErrorResumeNextSubscriber.prototype.subscribeToNextSource = function () {
var next = this.nextSources.shift();
if (!!next) {
OnErrorResumeNextSubscriber.prototype.subscribeToNextSource = function () {
var next = this.nextSources.shift();
if (!!next) {
- var innerSubscriber = new
InnerSubscriber(this, undefined, undefined
);
+ var innerSubscriber = new
SimpleInnerSubscriber(this
);
var destination = this.destination;
destination.add(innerSubscriber);
var destination = this.destination;
destination.add(innerSubscriber);
- var innerSubscription =
subscribeToResult(this, next, undefined, undefined
, innerSubscriber);
+ var innerSubscription =
innerSubscribe(next
, innerSubscriber);
if (innerSubscription !== innerSubscriber) {
destination.add(innerSubscription);
}
if (innerSubscription !== innerSubscriber) {
destination.add(innerSubscription);
}
@@
-74,5
+72,5
@@
var OnErrorResumeNextSubscriber = /*@__PURE__*/ (function (_super) {
}
};
return OnErrorResumeNextSubscriber;
}
};
return OnErrorResumeNextSubscriber;
-}(OuterSubscriber));
+}(
Simple
OuterSubscriber));
//# sourceMappingURL=onErrorResumeNext.js.map
//# sourceMappingURL=onErrorResumeNext.js.map