8390 var Subscription = function (observer, subscriber) {
8391   anObject(observer);
8393   this._o = observer;
8394   observer = new SubscriptionObserver(this);
8396     var cleanup = subscriber(observer);
8404     observer.error(e);  field
8421       var observer = subscription._o;
8423         var m = getMethod(observer.next);
8424         if (m) return m.call(observer, value);
8437     var observer = subscription._o;
8440       var m = getMethod(observer.error);
8442       value = m.call(observer, value);
8455       var observer = subscription._o;
8458         var m = getMethod(observer.complete);
8459         value = m ? m.call(observer, value) : undefined;
8477   subscribe: function subscribe(observer) {
8478     return new Subscription(observer, this._f);
8506       return observable.constructor === C ? observable : new C(function (observer) {  argument
8507         return observable.subscribe(observer);
8510     return new C(function (observer) {  argument
8516               observer.next(it);
8521             observer.error(e);
8523           } observer.complete();
8531     return new (typeof this === 'function' ? this : $Observable)(function (observer) {  argument
8536             observer.next(items[j]);
8538           } observer.complete();