Giant blob of minor changes
[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / _esm2015 / internal / operators / finalize.js
1 import { Subscriber } from '../Subscriber';
2 import { Subscription } from '../Subscription';
3 export function finalize(callback) {
4     return (source) => source.lift(new FinallyOperator(callback));
5 }
6 class FinallyOperator {
7     constructor(callback) {
8         this.callback = callback;
9     }
10     call(subscriber, source) {
11         return source.subscribe(new FinallySubscriber(subscriber, this.callback));
12     }
13 }
14 class FinallySubscriber extends Subscriber {
15     constructor(destination, callback) {
16         super(destination);
17         this.add(new Subscription(callback));
18     }
19 }
20 //# sourceMappingURL=finalize.js.map