rxjs http请求未缓存

Question

我正在尝试理解rxjs publishReplay，refCount和share我想要实现的是缓存http请求，如此处所述What is the correct way to share the result of an Angular Http network call in RxJs 5?

这就是我想出来的

export class TestService {

  constructor(private http: HttpClient) {}
  getData(): Observable<any> {
    return this.http.get('https://httpbin.org/anything').map((data: any) => {
    console.log('getting data');

      return Math.floor(Math.random() * 20);
    }).publishReplay(1).refCount();
  } 
}

叫它

t.getData().subscribe((data: any) => console.log(data));
t.getData().subscribe((data: any) => console.log(data));

请求通常会两次。

只是为了解原因：

我是否正确如果我第二次订阅时observable（http请求）尚未完成，则会发生此行为？

如果我在第一个订阅中移动第二个qazxsw poi，则只有一个请求是模式。

t.getData()

Answer 1

每次调用here is a stackblitz with the code方法时，它都会返回一个新的可观察对象 - 将冷可观察对象转换为热可观察对象并不重要。

更合适地使用getData()是为了保持Observable的相同实例。

例如：

.publishReplay

打电话给：

export class TestService {
  data: Observable<any>;
  constructor(private http: HttpClient) {
     this.data = this.getData();
  }
  getData(): Observable<any> {
    return this.http.get('https://httpbin.org/anything').map((data: any) =>{
    console.log('getting data');

      return Math.floor(Math.random() * 20);
    }).publishReplay(1).refCount();
  } 
}