Function patchRxJs

packages/zone.js/lib/rxjs/rxjs.ts:17–215

(Zone: ZoneType)

} & Subscriber<any>;

export function patchRxJs(Zone: ZoneType): void {
  (Zone as any).__load_patch('rxjs', (global: any, Zone: ZoneType, api: _ZonePrivate) => {
    const symbol: (symbolString: string) => string = (Zone as any).__symbol__;
    const nextSource = 'rxjs.Subscriber.next';
    const errorSource = 'rxjs.Subscriber.error';
    const completeSource = 'rxjs.Subscriber.complete';

    const ObjectDefineProperties = Object.defineProperties;

    const patchObservable = function () {
      const ObservablePrototype: any = Observable.prototype;
      const _symbolSubscribe = symbol('_subscribe');
      const _subscribe = (ObservablePrototype[_symbolSubscribe] = ObservablePrototype._subscribe);

      ObjectDefineProperties(Observable.prototype, {
        _zone: {value: null, writable: true, configurable: true},
        _zoneSource: {value: null, writable: true, configurable: true},
        _zoneSubscribe: {value: null, writable: true, configurable: true},
        source: {
          configurable: true,
          get: function (this: Observable<any>) {
            return (this as any)._zoneSource;
          },
          set: function (this: Observable<any>, source: any) {
            (this as any)._zone = Zone.current;
            (this as any)._zoneSource = source;
          },
        },
        _subscribe: {
          configurable: true,
          get: function (this: Observable<any>) {
            if ((this as any)._zoneSubscribe) {
              return (this as any)._zoneSubscribe;
            } else if (this.constructor === Observable) {
              return _subscribe;
            }
            const proto = Object.getPrototypeOf(this);
            return proto && proto._subscribe;
          },
          set: function (this: Observable<any>, subscribe: any) {
            (this as any)._zone = Zone.current;
            if (!subscribe) {
              (this as any)._zoneSubscribe = subscribe;
            } else {
              (this as any)._zoneSubscribe = function (this: ZoneSubscriberContext) {
                if (this._zone && this._zone !== Zone.current) {
                  const tearDown = this._zone.run(subscribe, this, arguments as any);
                  if (typeof tearDown === 'function') {
                    const zone = this._zone;
                    return function (this: ZoneSubscriberContext) {
                      if (zone !== Zone.current) {
                        return zone.run(tearDown, this, arguments as any);
                      }
                      return tearDown.apply(this, arguments);
                    };
                  } else {
                    return tearDown;
                  }