保证可观察的订阅在继续下一个代码之前完成

Question

我正在使用多个服务调用进行一些级联删除。一些后来的订阅依赖于以前的订阅来完成。如何保证订阅完成，然后再转到我的下一个代码？

// Need to make sure this code completes
data.forEach(element => {
    this.myService.delete(element.id).subscribe();
});

// Before running this code
this.myService.getAll().subscribe(res => {
        res.data.forEach(element => {
            this.myService.delete(element.id).subscribe();
        });
    }
);

Answer 1

Subscription 有一个独特的目的：处置，但你有选择：

• 如果要一个个订阅 observables，可以使用concat。

• 如果你想同时订阅多个 observables 并合并每个 observables 的最后一个值，你可以使用forkJoin。

• 如果你想在另一个 observable 中使用 observable 的 yield 值，你可以使用 flatMap。

---

import { forkJoin, interval, concat, of } from "rxjs";
import { first, flatMap } from "rxjs/operators";

var combinedIntervals =
    forkJoin(
        interval(1000).pipe(first()),
        interval(2500).pipe(first())
    ).pipe(
        flatMap(([a, b]) => of(`${a} and ${b}`))
    );

concat(
    combinedIntervals,
    of("after both intervals")
)
.subscribe(
    console.log.bind(console)
);


// 0 and 0
// after both intervals

---

对于您的具体情况，您可以选择删除操作作为可观察对象，然后 forkJoin。

var data = [];

var obsBatch1 = data.map(element => myService.delete(element.id));
var obsBatch2 =
    forkJoin(
        obsBatch1,
        elements => elements.map(
            element => myService.delete(element.id)
        )
    );

obsBatch2.subscribe();

---

这是rxjs@6 语法。我将rxjs@5 留作练习。