可并行观察

Question

我正在使用 Ionic 3 和 ReactiveX Observable 对象。我通过AngularFireDatabase 使用valueChanges() 方法获得了一个Observable。我想以某种方式过滤它，比如在另一个 Observable 中拥有一些具有特定属性的对象并对其进行排序。我使用Observable.forkJoin() 但它不起作用，因为我的启动画面没有隐藏。如果您需要，我可以附上一些代码。或者，也许你可以帮我举个例子。谢谢

这是我的代码

Observable.forkJoin([
  this.allParticipants = this.participantsList.valueChanges().map(res => res.sort((a, b) => a.name < b.name ? -1 : 1)),
  this.paidParticipants = this.allParticipants.map(res => res.filter(guest => guest.paid)),
]).subscribe(() => this.splashScreen.hide(), () => this.splashScreen.hide(), () => this.splashScreen.hide());

我将隐藏方法放在所有参数中，以查找它是否以某种方式隐藏但没有。

Answer 1

我认为forkJoin 在这里不起作用，因为它只会在所有可观察对象完成时发出。 valuesChanges() 未完成。使用combineLatest 或switchMap。