diff options
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.ts | 7 |
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); |