@@ -145,26 +145,28 @@ import {Observable, Subscriber, Subscription} from 'rxjs';
145
145
Subscriber . prototype . next = function ( ) {
146
146
const currentZone = Zone . current ;
147
147
const subscriptionZone = this . _zone ;
148
+ const args : [ any ?] = Array . prototype . slice . call ( arguments ) as [ any ?] ;
148
149
149
150
// for performance concern, check Zone.current
150
151
// equal with this._zone(SubscriptionZone) or not
151
152
if ( subscriptionZone && subscriptionZone !== currentZone ) {
152
153
return subscriptionZone . run ( next , this , arguments , nextSource ) ;
153
154
} else {
154
- return next . apply ( this , arguments ) ;
155
+ return next . apply ( this , args ) ;
155
156
}
156
157
} ;
157
158
158
159
Subscriber . prototype . error = function ( ) {
159
160
const currentZone = Zone . current ;
160
161
const subscriptionZone = this . _zone ;
162
+ const args : [ any ?] = Array . prototype . slice . call ( arguments ) as [ any ?] ;
161
163
162
164
// for performance concern, check Zone.current
163
165
// equal with this._zone(SubscriptionZone) or not
164
166
if ( subscriptionZone && subscriptionZone !== currentZone ) {
165
167
return subscriptionZone . run ( error , this , arguments , errorSource ) ;
166
168
} else {
167
- return error . apply ( this , arguments ) ;
169
+ return error . apply ( this , args ) ;
168
170
}
169
171
} ;
170
172
@@ -177,7 +179,7 @@ import {Observable, Subscriber, Subscription} from 'rxjs';
177
179
if ( subscriptionZone && subscriptionZone !== currentZone ) {
178
180
return subscriptionZone . run ( complete , this , arguments , completeSource ) ;
179
181
} else {
180
- return complete . apply ( this , arguments ) ;
182
+ return complete . call ( this ) ;
181
183
}
182
184
} ;
183
185
} ;
0 commit comments