Angular : how to call finally() with RXJS 6

Question

我之前使用的是 RXJS 5，现在升级到 6 后，我遇到了一些问题。

以前我能够使用catch和finally，但是根据更新catch被替换为catchError(在管道中)现在如何使用finally？

我还有一些问题:

我需要更改 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

• 使用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() 中使用的运算符。