39 var Subscription = function (observer, subscriber) {  argument
40   anObject(observer);
42   this._o = observer;
43   observer = new SubscriptionObserver(this);
45     var cleanup = subscriber(observer);
53     observer.error(e);
70       var observer = subscription._o;  variable
72         var m = getMethod(observer.next);
73         if (m) return m.call(observer, value);
86     var observer = subscription._o;
89       var m = getMethod(observer.error);
91       value = m.call(observer, value);
104       var observer = subscription._o;
107         var m = getMethod(observer.complete);
108         value = m ? m.call(observer, value) : undefined;
126   subscribe: function subscribe(observer) {
127     return new Subscription(observer, this._f);
155       return observable.constructor === C ? observable : new C(function (observer) {  argument
156         return observable.subscribe(observer);
159     return new C(function (observer) {  argument
165               observer.next(it);
170             observer.error(e);
172           } observer.complete();
180     return new (typeof this === 'function' ? this : $Observable)(function (observer) {  argument
185             observer.next(items[j]);
187           } observer.complete();