zheng/blog-frontEnd
1
0
Fork 0
Code Issues 2 Pull Requests 12 Actions Packages Projects Releases Wiki Activity

清理代码

Browse Source
This commit is contained in:
禾几海
2020-08-05 21:38:21 +08:00
parent 01c21f5732
commit 6fb62adb91
1 changed files with 2 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/app/api/http/http.service.ts
View File

@@ -1,9 +1,8 @@
import {forwardRef, Inject, Injectable, Injector} from '@angular/core'; import {Injectable, Injector} from '@angular/core';
import {RequestObj} from '../../class/HttpReqAndResp'; import {RequestObj, Response} from '../../class/HttpReqAndResp';
import {HttpClient, HttpResponse} from '@angular/common/http'; import {HttpClient, HttpResponse} from '@angular/common/http';
import {environment} from '../../../environments/environment'; import {environment} from '../../../environments/environment';
import {LocalStorageService} from '../../services/local-storage.service'; import {LocalStorageService} from '../../services/local-storage.service';
import {Response} from '../../class/HttpReqAndResp';
import {Observable, Observer, Subscription} from 'rxjs'; import {Observable, Observer, Subscription} from 'rxjs';
import {ErrorService} from '../../services/error.service'; import {ErrorService} from '../../services/error.service';
@@ -19,14 +18,8 @@ export class HttpService {
private subscriptionQueue: Subscription[] = []; private subscriptionQueue: Subscription[] = [];
// private errorDispatch: ErrDispatch;
public getSubscriptionQueue = () => this.subscriptionQueue; public getSubscriptionQueue = () => this.subscriptionQueue;
// setErrDispatch(errDispatch: ErrDispatch) {
// this.errorDispatch = errDispatch;
// }
Service<T>(request: RequestObj) { Service<T>(request: RequestObj) {
const errorService = this.injector.get(ErrorService); const errorService = this.injector.get(ErrorService);
request.url = null; request.url = null;
@@ -70,9 +63,6 @@ export class HttpService {
if (o.body.code !== 0) { if (o.body.code !== 0) {
observer.error(o.body); observer.error(o.body);
errorService.httpException(o.body) errorService.httpException(o.body)
// if (this.errorDispatch) {
// this.errorDispatch.errHandler(o.body.code, o.body.msg, request);
// }
} else { } else {
observer.next(o.body); observer.next(o.body);
} }