Angular : how to call finally() with RXJS 6

Question

I was using RXJS 5, now as I upgraded it to 6, I am facing some problems.

Previously I was able to use catch and finally but as per update catch is replaced with catchError (with in the pipe) now how to use finally?

Also I have some questions :

Do I need to change throw->throwError (in below code Observable.throw(err);)

import { Observable, Subject, EMPTY, throwError } from "rxjs";
import { catchError } from 'rxjs/operators';

return next.handle(clonedreq).pipe(
          catchError((err: HttpErrorResponse) => {
        if ((err.status == 400) || (err.status == 401)) {
            this.interceptorRedirectService.getInterceptedSource().next(err.status);
            return Observable.empty();
        } else {
            return Observable.throw(err);
        }
       }) 
        //, finally(() => {
        //  this.globalEventsManager.showLoader.emit(false);
        //});
      );

Also how to use publish().refCount() now ?

score 36 · Accepted Answer · answered Jul 05 '18 at 13:49

36

use throwError instead of Observable.throw, see https://github.com/ReactiveX/rxjs/blob/master/docs_app/content/guide/v6/migration.md#observable-classes
finally was renamed to finalize and you'll use it inside pipe() among other operators.
the same with publish() and refCount(). Both are operators you'll use inside pipe().

answered Jul 05 '18 at 13:49

martin

93,354
25
191
226

can u pl tell me how to use publish with refcount in "readonly notification$: Observable = this._notification.asObservable().pipe(publish());" – Sunil Kumar Jul 05 '18 at 14:04
`.pipe(publish(), refCount())` – martin Jul 05 '18 at 14:05
well since RxJS 6 all operators are functions. Until RxJS 5 operators were methods on the `Observable` class. – martin Jul 05 '18 at 14:07

score 34 · Answer 2 · edited May 31 '19 at 10:16

34

Need to import finalize from rxjs/operators.

import { finalize } from 'rxjs/operators';

Then finalize is used inside the pipe(),

observable()
    .pipe( 
         finalize(() => {
              // Your code Here
         })
     )
    .subscribe();

edited May 31 '19 at 10:16

styopdev

2,604
4
34
55

answered Aug 08 '18 at 06:03

20B2

2,011
17
30

1

finalize has no argument. – Halil İbrahim Oymacı Jan 22 '19 at 13:31

score 2 · Answer 3 · answered Jan 22 '19 at 13:46

According to official document, You should change your code like this to avoid compile error: (You must throw exception in catchError method. finalize callback method has no argument.)

import { catchError, finalize } from 'rxjs/operators';

return next.handle(clonedreq).pipe(
  catchError(error => {
    console.log('error occured:', error);
    throw error;
  }),
  finalize(() => {
    console.log('finalize')
  })
);

It is successfully compiled in Angular CLI: 7.1.4.

Angular : how to call finally() with RXJS 6

3 Answers3

Linked

Related