Observable Finally on Subscribe

by

The current “pipable” variant of this operator is called finalize() (since RxJS 6). The older and now deprecated “patch” operator was called finally() (until RxJS 5.5).

I think finalize() operator is actually correct. You say:

do that logic only when I subscribe, and after the stream has ended

which is not a problem I think. You can have a single source and use finalize() before subscribing to it if you want. This way you’re not required to always use finalize():

let source = new Observable(observer => {
  observer.next(1);
  observer.error('error message');
  observer.next(3);
  observer.complete();
}).pipe(
  publish(),
);

source.pipe(
  finalize(() => console.log('Finally callback')),
).subscribe(
  value => console.log('#1 Next:', value),
  error => console.log('#1 Error:', error),
  () => console.log('#1 Complete')
);

source.subscribe(
  value => console.log('#2 Next:', value),
  error => console.log('#2 Error:', error),
  () => console.log('#2 Complete')
);

source.connect();

This prints to console:

#1 Next: 1
#2 Next: 1
#1 Error: error message
Finally callback
#2 Error: error message

Jan 2019: Updated for RxJS 6

More Related Contents:

  1. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  2. What are the semantics of different RxJS subjects?
  3. Chaining Observables in RxJS
  4. How to achieve a debounce service on input keyup event in angular2 with rxjs
  5. Angular 7 go offline?
  6. How to get current value of RxJS Subject or Observable?
  7. BehaviorSubject vs Observable?
  8. How can I close a dropdown on click outside?
  9. What is “callback hell” and how and why does RX solve it?
  10. How can I `await` on an Rx Observable?
  11. Subject vs BehaviorSubject vs ReplaySubject in Angular
  12. Promise.all behavior with RxJS Observables?
  13. How to do the chain sequence in rxjs
  14. RxJS Promise Composition (passing data)
  15. RxJS sequence equivalent to promise.then()?
  16. Rxjs One Observable Feeding into Another
  17. Angular 2 – Chaining http requests
  18. Rxjs toPromise() deprecated
  19. What are use cases for mergeMap operator?
  20. How to make one Observable sequence wait for another to complete before emitting?
  21. How to cancel a subscription in Angular2
  22. Is it good to call subscribe inside subscribe?
  23. What is the difference between Observable and a Subject in rxjs?
  24. How to ‘wait’ for two observables in RxJS
  25. What is the difference between BehaviorSubject and Observable?
  26. Return an empty Observable
  27. Upgrading to Angular 10 – Fix CommonJS or AMD dependencies can cause optimization bailouts
  28. Property ‘catch’ does not exist on type ‘Observable’
  29. How to catch error and continue executing a sequence in RxJs?
  30. How to implement a global loader in Angular

Leave a Comment