diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/internal/Observable.js')
| -rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/internal/Observable.js | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/Observable.js b/tools/node_modules/eslint/node_modules/rxjs/internal/Observable.js index e05cfc3350..693947bbce 100644 --- a/tools/node_modules/eslint/node_modules/rxjs/internal/Observable.js +++ b/tools/node_modules/eslint/node_modules/rxjs/internal/Observable.js @@ -1,5 +1,6 @@ "use strict"; Object.defineProperty(exports, "__esModule", { value: true }); +var canReportError_1 = require("./util/canReportError"); var toSubscriber_1 = require("./util/toSubscriber"); var observable_1 = require("../internal/symbol/observable"); var pipe_1 = require("./util/pipe"); @@ -24,7 +25,7 @@ var Observable = (function () { operator.call(sink, this.source); } else { - sink._addParentTeardownLogic(this.source || (config_1.config.useDeprecatedSynchronousErrorHandling && !sink.syncErrorThrowable) ? + sink.add(this.source || (config_1.config.useDeprecatedSynchronousErrorHandling && !sink.syncErrorThrowable) ? this._subscribe(sink) : this._trySubscribe(sink)); } @@ -47,7 +48,12 @@ var Observable = (function () { sink.syncErrorThrown = true; sink.syncErrorValue = err; } - sink.error(err); + if (canReportError_1.canReportError(sink)) { + sink.error(err); + } + else { + console.warn(err); + } } }; Observable.prototype.forEach = function (next, promiseCtor) { |