组合CombineTest和switchMap时未定义

Question

我试图将两个可观察对象组合起来，使接受两个值的调用服务方法具有几个值。但这里我有一些错误

>

控制台中-

您在需要流的位置提供了“未定义”。您可以提供一个可观察的、promise的、数组的或可观察的。在SwitchMapSubscriber的innerSubscribe（innerSubscribe.js:71）的subscribeTo（subscribeTo.js:27）_SwitchMapSubscriber上的innerSub（switchMap.js:44）_接下来（switchMap.js:34）在SwitchMapSubscriber上。下一个（Subscriber.js:49）在CombineLatestSubscriber。InnerSubscriber上的notifyNext（combineLatest.js:73）_下一步（InnerSubscriber.js:11）在InnerSubscriber。下一步（Subscriber.js:49）在BehaviorSubject_在BehaviorSubject订阅（BehaviorSubject.js:14）_trySubscribe（observeable.js:42）

>

定义观察对象和对象。

 private openSortQuerySubject: BehaviorSubject<string> = new BehaviorSubject<string>(this.formatSortQuery(this.multiSortMeta));
 public openSortQuery: Observable<string> = this.openSortQuerySubject.asObservable();

 private closedSortQuerySubject: BehaviorSubject<string> = new BehaviorSubject<string>(this.formatSortQuery(this.multiSortMeta));
 public closedSortQuery = this.closedSortQuerySubject.asObservable();

合并观测值。

   const openQueries$ = combineLatest([this.openFilterQuery, this.openSortQuery]);
   const closedQueries$ = combineLatest([this.closedFilterQuery, this.closedSortQuery]);

在服务方法中使用合并的值。

openQueries$
      .pipe(
        switchMap(([filter, sort]) => {
          this.alertService
            .listAlerts(filter, sort);
        }),
        tap(v => console.log(v))
      )
      .subscribe((openAlerts) => {
        this.openAlertsCount = openAlerts.length;
        this.openAlerts = this.parseAlerts(openAlerts);
      });

    closedQueries$
      .pipe(
        switchMap(([filter, sort]) => {
          this.alertService
            .listAlerts(filter, sort);
        })
      )
      .subscribe((closedAlerts) => {
        this.closedAlertsCount = closedAlerts.length;
        this.closedAlerts = this.parseAlerts(closedAlerts);
      });

Answer 1

您必须在switchMap回调中返回一个可观察对象（或者RxJS知道如何将其转换为可观察对象）。

不是这个：

switchMap(([filter, sort]) => {
  this.alertService.listAlerts(filter, sort);
})

但是这（假设listAlerts返回一个可观察的、promise的或类似的）：

switchMap(([filter, sort]) => {
  return this.alertService.listAlerts(filter, sort);
})