异步分支和同步分支使用 Angular Observable 相遇

Question

假设我们有一个像这样的简单伪代码 sn-p：

if (myCondition){
  // Async branch
  myObservable
    .somethingAsync()
    .subscribe(x => {
      doSomething(x);
    });
} else {
  // Sync branch
  somethingSync();
}
continueBothHere();

所以，一个异步分支和一个同步分支，其中 continueBothHere() 总是在 if 语句之后执行。 假设 continueBothHere() 不需要来自任一分支的任何输入。

如何使用 Observables 实现这一点？

我想我想在 if 语句 before 定义一个 Observable，所以我可以在 if 语句 after 使用它来加入分支？但这可以与真正分支中的 observable 相结合吗？如果有的话，我对 false 分支中的那个 Observable 说什么？也许这可以在不使用 if 语句的情况下实现？

---

明确一点：在真正的分支中，我希望在执行 doSomething(x) 之后再执行 continueBothHere()

Answer 1

当我处理observable 时，我想将其包含到异步链或同步和异步操作中，这应该具有相同的后续步骤，我通常从new Promise 开始。这样，您可以轻松地使您的代码异步并处理 then 块内的数据：

new Promise (resolve => {
  if (myCondition){
    // Async branch
    myObservable
      .somethingAsync()
      .take(1)
      .subscribe(x => {
        resolve(doSomething(x));
      });
  } else {
    // Sync branch
    resolve(somethingSync());
  }
})
.then(data => {
  // "data" will contain the result of "doSomething(x)" or "somethingSync()" execution, depending on "if" statement
  continueBothHere();
})

Answer 2

您可以将同步分支包装到 Observable 中并在任何地方订阅结果。

checkCondition():Observable<any>{
 if (myCondition){
  // Async branch
  return myObservable.somethingAsync();
 } else {
  // Sync branch
  return Observable.of(somethingSync());
}

this.checkCondition.subscribe(result=>continueBothHere());