等待多个Promise完成

Question

我正在使用 Ionic 平台的 SQLStorage。

remove

函数返回一个承诺。在我的代码中，我需要删除多个值。当这些都完成后，我需要执行一些代码。

如何等待所有这些然后执行回调函数？

代码：

removeAll() {    
  this.storage.remove(key1);
  this.storage.remove(key2);
  this.storage.remove(key3);    
}

全部嵌套是一种不好的做法，所以我正在寻找一个不错的解决方案:)

removeAll() {
  return this.storage.remove(key1).then(() => {
    this.storage.remove(key2).then(() => {
      this.storage.remove(key3);        
    });
  });
};

Answer 1

你可以使用

removeAll() {
  Promise.all([
    this.storage.remove(key1),
    this.storage.remove(key2),
    this.storage.remove(key3),
  ]).then(value => doSomething());

value

是一个数组，其中包含按顺序传递给

Promise.all([...])

匹配的每个异步调用的返回值。

另请参阅 https://developer.mozilla.org/en/docs/Web/JavaScript/Reference/Global_Objects/Promise/all

Answer 2

您可以通过提供所有

Observable.forkJoin

的数组来使用

rxjs

中的

observables/promises

。这需要在执行操作之前完成。它类似于 Angular 1 的

$q.all

。

rxjs版本<= 6

Observable.forkJoin([
   this.storage.remove(key1), 
   this.storage.remove(key2),
   this.storage.remove(key3)
])
.subscribe(t=> {
    var firstResult = t[0];
    var secondResult = t[1];
});

rxjs 版本 > 6

import {forkJoin} from 'rxjs';

forkJoin([
   this.storage.remove(key1), 
   this.storage.remove(key2),
   this.storage.remove(key3)
])
.subscribe(t=> {
    var firstResult = t[0];
    var secondResult = t[1];
});

Answer 3

在

rxjs

版本 > 6 您可以执行以下操作：

import {forkJoin} from 'rxjs';

并执行以下操作来代替

Observable.forkJoin

：

forkJoin([
  this.service1.get(),
  this.service2.get()
]).subscribe(data => {
  this.data1= data[0];
  this.data2 = data[1];

Answer 4

我不熟悉 IONIC，但假设 storage.remove 返回一个承诺，我建议您使用 observables 中的 forkJoin 运算符。

forkJoin 接受一个可观察数组并等待所有项目的执行。

请注意，我必须根据 .remove 方法返回的每个 Promise 创建 3 个新的可观察值。

Observable.forkJoin([
   Observable.fromPromise(this.storage.remove(key1)), 
   Observable.fromPromise(this.storage.remove(key2)),
   Observable.fromPromise(this.storage.remove(key3))
])
.subscribe(data => {
    console.log(data[0]);
    console.log(data[1]);
    console.log(data[2]);
});

Answer 5

使用 Promise.all():

Promise.all(iterable) 方法返回一个 Promise，当可迭代参数中的所有 Promise 都已解决时，该 Promise 会被解析，或者由于第一个传递的 Promise 被拒绝的原因而被拒绝。

语法

Promise.all(iterable);

参数

可迭代

可迭代对象，例如数组。请参阅可迭代。

Answer 6

使用 Promise.all 表示 Promise，使用 Observable.forkJoin 表示 Observables

因为问题是关于 Angular(2+) 的，你可能应该使用 Observable 而不是 Promise。我将添加一个对我有用的 GET 示例：

import {Observable} from 'rxjs/Rx';
    
Observable.forkJoin(
      this._dataService.getOne().map(one => this.one = one),
      this._dataService.getTwo().map(two => this.two = two),
      this._dataService.getN().map(n => this.n = n),
     )
    ).subscribe(res => this.doSomethingElse(this.one, this.two, this.n)); 

注意使用一个 .map() 来处理响应而不是 .subscribe()