Angular: как позвонить finally () с помощью RXJS 6

Question

Я использовал RXJS 5, теперь, когда я обновил его до 6, я столкнулся с некоторыми проблемами.

Раньше я мог использовать catch и, наконец, но в соответствии с обновлением catch заменяется на catchError (с в канале), теперь как использовать наконец?

Также у меня есть несколько вопросов:

Нужно ли мне менять throw-> throwError (в приведенном ниже коде 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);
        //});
      );

Также, как теперь использовать publish (). RefCount ()?

Answer 1

Необходимо импортировать finalize из rxjs/operators.

import { finalize } from 'rxjs/operators';

Затем finalize используется внутри pipe(),

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

Answer 2

Согласно официальному документу , вы должны изменить свой код следующим образом, чтобы избежать ошибки компиляции: (Вы должны вызвать исключение в методе catchError. finalize Метод обратного вызова не имеет аргумента.)

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

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

Успешно скомпилировано в Angular CLI: 7.1.4.

Answer 3

• используйте throwError вместо Observable.throw, см. https://github.com/ReactiveX/rxjs/blob/master/docs_app/content/guide/v6/migration.md#observable-classes

• finally был переименован в finalize, и вы будете использовать его внутри pipe() среди других операторов.

• то же самое с publish() и refCount(). Оба оператора вы будете использовать внутри pipe().