From a6b375ab89c80f012bca3f5abf26686f0bbee118 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=8D=A1=E8=89=B2?= Date: Wed, 3 Feb 2021 15:33:31 +0800 Subject: [PATCH] fix(theme:_HttpClient): fix count when subscribed (#1157) --- packages/theme/src/services/http/http.client.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/theme/src/services/http/http.client.ts b/packages/theme/src/services/http/http.client.ts index 2b4a55782..e07aee050 100644 --- a/packages/theme/src/services/http/http.client.ts +++ b/packages/theme/src/services/http/http.client.ts @@ -3,7 +3,7 @@ import { Injectable } from '@angular/core'; import { AlainConfigService, AlainThemeHttpClientConfig } from '@delon/util/config'; import { NzSafeAny } from 'ng-zorro-antd/core/types'; import { Observable, of } from 'rxjs'; -import { finalize, switchMap } from 'rxjs/operators'; +import { finalize, switchMap, tap } from 'rxjs/operators'; export type _HttpHeaders = HttpHeaders | { [header: string]: string | string[] }; export type HttpObserve = 'body' | 'events' | 'response'; @@ -981,9 +981,9 @@ export class _HttpClient { withCredentials?: boolean; } = {}, ): Observable { - this.push(); if (options.params) options.params = this.parseParams(options.params); return of(null).pipe( + tap(() => this.push()), switchMap(() => this.http.request(method, url, options)), finalize(() => this.pop()), );