7604 var Subscription = function (observer, subscriber) {
7605   anObject(observer);
7607   this._o = observer;
7608   observer = new SubscriptionObserver(this);
7610     var cleanup = subscriber(observer);
7618     observer.error(e);  field
7635       var observer = subscription._o;
7637         var m = getMethod(observer.next);
7638         if (m) return m.call(observer, value);
7651     var observer = subscription._o;
7654       var m = getMethod(observer.error);
7656       value = m.call(observer, value);
7669       var observer = subscription._o;
7672         var m = getMethod(observer.complete);
7673         value = m ? m.call(observer, value) : undefined;
7691   subscribe: function subscribe(observer) {
7692     return new Subscription(observer, this._f);
7720       return observable.constructor === C ? observable : new C(function (observer) {  argument
7721         return observable.subscribe(observer);
7724     return new C(function (observer) {  argument
7730               observer.next(it);
7735             observer.error(e);
7737           } observer.complete();
7745     return new (typeof this === 'function' ? this : $Observable)(function (observer) {  argument
7750             observer.next(items[j]);
7752           } observer.complete();