summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts7
1 files changed, 6 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts
index 4aefc2f755..d40e4fb6a4 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts
+++ b/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/bindNodeCallback.ts
@@ -3,6 +3,7 @@ import { AsyncSubject } from '../AsyncSubject';
import { Subscriber } from '../Subscriber';
import { SchedulerAction, SchedulerLike } from '../types';
import { map } from '../operators/map';
+import { canReportError } from '../util/canReportError';
import { isScheduler } from '../util/isScheduler';
import { isArray } from '../util/isArray';
@@ -198,7 +199,11 @@ export function bindNodeCallback<T>(
try {
callbackFunc.apply(context, [...args, handler]);
} catch (err) {
- subject.error(err);
+ if (canReportError(subject)) {
+ subject.error(err);
+ } else {
+ console.warn(err);
+ }
}
}
return subject.subscribe(subscriber);