aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js2
1 files changed, 1 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js
index a093a76de4..bc603ce7f5 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/Observable.js
@@ -20,7 +20,7 @@ export class Observable {
const { operator } = this;
const sink = toSubscriber(observerOrNext, error, complete);
if (operator) {
- operator.call(sink, this.source);
+ sink.add(operator.call(sink, this.source));
}
else {
sink.add(this.source || (config.useDeprecatedSynchronousErrorHandling && !sink.syncErrorThrowable) ?