super(destination);
}
- notifyNext(outerValue: T, innerValue: any,
- outerIndex: number, innerIndex: number,
+ notifyNext(outerValue: T, _innerValue: any,
+ _outerIndex: number, _innerIndex: number,
innerSub: InnerSubscriber<T, R>): void {
- this.destination.next(outerValue);
+ this.destination.next!(outerValue);
this.removeSubscription(innerSub);
this.tryComplete();
}
notifyComplete(innerSub: InnerSubscriber<T, R>): void {
const value = this.removeSubscription(innerSub);
if (value) {
- this.destination.next(value);
+ this.destination.next!(value);
}
this.tryComplete();
}
this.tryDelay(delayNotifier, value);
}
} catch (err) {
- this.destination.error(err);
+ this.destination.error!(err);
}
}
private tryComplete(): void {
if (this.completed && this.delayNotifierSubscriptions.length === 0) {
- this.destination.complete();
+ this.destination.complete!();
}
}
}