1 import { Subscriber } from '../Subscriber';
2 import { Subscription } from '../Subscription';
3 export function finalize(callback) {
4 return (source) => source.lift(new FinallyOperator(callback));
6 class FinallyOperator {
7 constructor(callback) {
8 this.callback = callback;
10 call(subscriber, source) {
11 return source.subscribe(new FinallySubscriber(subscriber, this.callback));
14 class FinallySubscriber extends Subscriber {
15 constructor(destination, callback) {
17 this.add(new Subscription(callback));
20 //# sourceMappingURL=finalize.js.map