javascript - 如何返回具有 Angular 可观察值的数字/变量？

Question

我有一个 Angular 服务调用 API 并返回大量数据。在同一个 GET 调用中，我正在执行一些逻辑来计算每种类型的数量。我的问题很简单，我可以将该变量/数字与数据一起发回，甚至可以将其保存到另一个变量并发送吗？

当我尝试将它作为公共(public)变量保存到服务时，当我尝试将它拉入另一个组件时它是未定义的。我假设是因为在订阅 observable 之前访问了变量，但我不知道如何解决这个问题？

在下面的代码中，_counts 是我要返回的，它在 getPciInfo 方法中的日志记录工作正常，但就像我说的，它在其他任何地方返回时都是未定义的。 (我试图将这个数字传递给不同的组件)。

感谢您提供的任何帮助或建议。

public _counts: any;

getPciInfo(): Observable <Ipcidata[]> {
    return this.httpClient.get<Ipcidata[]>('http://dr0-hlp-07/api/PCIMachines')
      .pipe(
              map(results => {

                const sorted = results.sort(( a, b ) => {
                      const updateDateA = Date.parse(this.datepipe.transform(a.UpdatedDate, 'MM-dd-yyyy'));
                      const carda = determineCardType(a, this.dateMinusMonth, this.dateMinusTwoWeeks)
                      const cardb = determineCardType(b, this.dateMinusMonth, this.dateMinusTwoWeeks)

                      return cardb - carda
                });

                this._counts = sorted.reduce((acc, cur)=>{
                  const cardType = determineCardType(cur, this.dateMinusMonth, this.dateMinusTwoWeeks)

                  switch (cardType) {
                    case 1:
                      acc.green += 1;
                      break;
                    case 2:
                      acc.yellow += 1;
                      break;
                    case 3:
                      acc.red += 1;
                      break;
                  }
                  return acc;
                }, {
                  red: 0,
                  green: 0,
                  yellow: 0
                });
                console.log(this._counts)
                console.log(this._counts.red)

          return sorted;
          }

Answer 1

要发回您可以执行的计数:

return ({sorted, counts: _counts});

要跨此服务的组件共享它，您可以有一个主题，例如:

private countsSource = new Subject();
private counts = this.countsSource.asObservable();

getPciInfo(): Observable <Ipcidata[]> {
    return this.httpClient.get<Ipcidata[]>('http://dr0-hlp-07/api/PCIMachines')
      .pipe(
              map(results => {
                 ....
                 const counts = ...
                 this.countsSource.next(counts)
              });
}

getCounts(): Observable<CountData> {
     return this.counts;
}

在一个组件中，您可以像使用其他函数一样使用它

this.myService.getCounts().subscribe(counts => console.log(counts));

如果您希望将计数发送到新订阅，您可能必须使用 BehaviorSubject 或 ReplaySubject。