RxJS / Angular2：为什么我的主题订阅者没有被调用？

Question

我有一个数据服务，它通过 HTTP（由某些组件触发）运行查询，然后通过 Observable 公开结果。其他组件将订阅该Observable 并更新其结果视图。

无论如何，这就是想法，但它不起作用。这是我的代码。

ItemListDataService：

import { Injectable } from '@angular/core';
import { Http, Response } from '@angular/http';
import { Observable, Subject } from "rxjs";
import 'rxjs/add/operator/map';

@Injectable()
export class ItemListDataService {
  private issues$: Subject<any>;

  constructor(private http: Http) {
    this.issues$ = new Subject();
    this.issues$.subscribe(x => console.log('GOT IT', x));
  }

  getList(): Observable<any> {
    return this.issues$;
  }

  refresh() {
    this.http.get('/whatever')
      .map((response: Response) => response.json())
      .subscribe(data => this.issues$.next(data));
  }
}

ItemListComponent：

import { Component } from '@angular/core';
import { Observable } from 'rxjs';

import { ItemListDataService } from './item-list-data-service';
@Component({
  selector: 'app-item-list',
  templateUrl: './item-list.component.html',
  styleUrls: ['./item-list.component.css'],
  providers: [ItemListDataService]
})
export class ItemListComponent {
  data: any;

  constructor(itemListDataService: ItemListDataService) {
    itemListDataService.getList().subscribe(data => {
      console.log('DATA CHANGED');
      this.data = data;
    }, err => {
      console.log('ERR', err)
    }, () => {
      console.log('DONE');
    });
  }
}

每次调用refresh() 时都会调用在ItemListDataService.constructor 中创建的订阅者。唯一不起作用的是组件中的订阅 - 那里从未调用任何回调。

我做错了什么？

Answer 1

正如 JB Nizet 在评论中指出的那样，原因是该服务不是单例的，即每个订阅者都有一个新实例。与 Angular 1 不同，A2 中的服务不是单例的。

为了让多个服务/组件共享一个服务实例，请将其放在父@Component 或@NgModule 的提供者中。