4c478bc46a3cca0786340e1e72f5a2a9215333deb097b525cbb8aff643cef15bf26e931e798fd665457c68d41193741670dbb356f427cacc0b18c378f51b3a 616 B

1234567891011121314151617181920
  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