import { config } from './config';
import { hostReportError } from './util/hostReportError';
export const empty = {
closed: true,
next(value) { },
error(err) {
if (config.useDeprecatedSynchronousErrorHandling) {
throw err;
}
else {
hostReportError(err);
},
complete() { }
};
//# sourceMappingURL=Observer.js.map
ExtensibilityExtensibility
所以toSubscriber返回的实际是一个subscriber对象：
首先调用subscriber对象的add方法，目的是通过这个三元表达式，判断到底应该调用subscribe方法，还是trySubscribe方法：
在我的Angular10，执行后者：
记住这个语义：Observable的subscribe方法，输入参数为subscriber：
_trySubscribe调用_subscribe:
然后就执行到了之前用subscribeToArray返回的function内部：
注意在这个上下文里，我们既有输入，又有应用程序传入的subscribe函数，因此可以调用next了：
next和_next的区别就在于有个this.isStopped的判断：
注意语义：Observable调用subscribe，而subscriber调用next.
subscriber的desination里包含了应用程序传入的callback：
subscriber的_tryOrUnsub函数里，最终调用应用程序的callback：
