rxjs - 无法从Interceptor订阅数据

Question

在我的AppComponent.ts文件中，我使用 HttpClient 进行了 HTTP GET 调用。

import { Component } from '@angular/core';
import { Observable, Subscriber, Unsubscribable } from 'rxjs';
import { HttpClient } from '@angular/common/http';

@Component({
  selector: 'app-root',
  templateUrl: './app.component.html',
  styleUrls: ['./app.component.css']
})
export class AppComponent {
  title = 'app';
  ob: Observable<any> = null;

  constructor(private httpClient: HttpClient) {

    httpClient.get("").subscribe((response) => {
      console.log(response);
    });
  }
}

然后我还有一个拦截器，它拦截 Http 调用并返回一些静态数据(例如缓存)。

import { Injectable } from "@angular/core";
import { HttpEvent, HttpInterceptor, HttpHandler, HttpRequest } from '@angular/common/http';
import { Observable, of } from "rxjs";

@Injectable()
export class CustomHttpInterceptor implements HttpInterceptor {
    intercept(req: HttpRequest<any>, next: HttpHandler): Observable<any> {
        return of({});
    }
}

但是AppComponent.ts中的订阅文件，没有收到任何回复。事实上，订阅成功或错误函数甚至没有被命中。 也没有控制台错误。有人知道这里发生了什么吗？

注意 我已将返回类型从 Observable<HttpEvent<any>> 更改为至Observable<any>因为 TypeScript 无法转换 Observable<{}>至Observable<HttpEvent<any>> .

Answer 1

您的缓存响应类型必须为 HttpResonse ，但更准确地说，它需要是 HttpEvent 类型，其中包括类 HttpResponse<T> :

const response = new HttpResponse<object>({
  body: {},
  status: 200
})

return of(response);

这有点未经测试，不确定 body 是否需要是可解析的 json 字符串才能使其工作:body: '{}' ，但这需要你去尝试。 :)