错误：类型 'OperatorFunction<{}、{} 上不存在属性 'subscribe' |可观察的<任何>>

Question

为什么我不能订阅 concat() 运算符的结果，即使它看起来与文档和示例中的相同 https://rxjs-dev.firebaseapp.com/api/index/function/concat

我已经尝试更改为 concatMap 或 concatAll 但我有更多问题，此解决方案是迄今为止我发现的最优雅的解决方案。

ngOnInit() {
    const trendingRentals = this.rentalService.getRentals().pipe(delay(500));
    const commonRentals = this.rentalService.getCommonRentalsTest().pipe(delay(1000));
    const luxuryRentals = this.rentalService.getLuxuryRentalsTest().pipe(delay(1500));

    const concatenation =  concat( [trendingRentals, commonRentals, luxuryRentals]);
    concatenation.subscribe(
      //Print result
    )
  }

    //All get request are equal but with a different endpoint
    public getCommonRentalsTest(): Observable<any> {
      return this.http.get('/api/v1/rentals/common');
    }

加快的结果是按顺序获取所有租金，然后以相同的顺序将它们推送到结果数组。

Answer 1

看起来您需要'static' factory function 而不是concat operator：

// Find:
import { concat } from 'rxjs/operators';

// Replace:
import { concat } from 'rxjs';

该运算符与另一个 observable 的 pipe 方法一起使用。例如：

const stream1$: Observable<any> = ...;
const stream2$: Observable<any> = ...;

const concatenated = stream1$.pipe(
    concat(stream2$)
);