的if / else if / else语句与观察为条件

Question

我想创建一个方法返回可以存储在三个位置之一的设置。我已经创建了三个观测，每一个试图检索源的设定值。我希望能够“参与”，这些以这样的方式来创建的if / else if / else语句构造，使得只有观测量的一个发射最终设定值。条件移动从一个可观察到下一个离开的是，以前的“失败”，即发射的未通过条件的值。其中每个选项是尝试的顺序很重要。

所以我的方法看起来像这样至今：

getSetting(settingName: string): Observable<any> {

    const optionOne$ = this.getItemAtFirst(settingName).pipe(
        take(1),
        filter(setting => setting && this.isSettingValid(settingName, setting)));

    const optionTwo$ = this.getItemAtSecond().pipe(
        take(1),
        filter(setting => setting && this.isSettingValid(settingName, setting)));

    const optionThree$ = of(this.defaultSettingValue);

    return merge(optionOne$, optionTwo$, optionThree$);
}

这显然是行不通的，因为merge不提供选择的效果，我需要。

有什么建议么？提前致谢！

Answer 1

编辑：TL; DR

与merge更换concat并添加first在您concat管道：

concat(optionOne$, optionTwo$, optionThree$)
    .pipe(
        first()
    );

concat订阅顺序给每个观察到的，这意味着optionOne$订阅首先，它会发出自己的价值观，它完成时，它是退订，然后concat订阅optionTwo$，等等......直到所有的观测完成，然后最后发出的所有的值作为数组。添加first简单地削减这个过程很短，因为它完成发射的第一个值后的CONCAT。

你真的需要检查所有concat内的观测将完成，或者你可以结束了，其中一人从未发出或完成的条件，这将意味着你将永远不会得到concat发出的值。

—-

假设你isSettingValid()如果验证失败返回false，则只需添加一个pipe()与first()到concat()。见稍作修改的版本下方，stackblitz这里。

这article也是翔实。我建议这个article这对于解释运营商和它们是如何工作的GIF爽 - 我总是会回来，就当我试图找出这样的事情。

我觉得这个回答你的问题，因为它发射出经过验证，忽略其余部分的第一个值。

import { of, Observable,  concat } from 'rxjs';
import { take, filter, first } from 'rxjs/operators';

function isSettingValid(setting): boolean {
  return setting !== 'error' ? true : false;
}

function getSetting(): Observable<any> {

  const optionOne$ = of('error')
    .pipe(
      take(1),
      filter(setting => isSettingValid(setting))
    );

  const optionTwo$ = of('second')
    .pipe(
      take(1),
      filter(setting => isSettingValid(setting))
    );

  const optionThree$ = of('default').pipe(
    take(1),
    filter(setting => isSettingValid(setting))
  );

  return concat(optionOne$, optionTwo$, optionThree$)
    .pipe(
      first() // emits only the first value which passes validation then completes
    );
}

getSetting()
  .subscribe((setting) => {
    console.log(setting);
  })

我也建议在我的片段去除setting &&一样，并把空校验你的验证函数里面 - 它只是使过滤器更容易，如果你这样做IMO这种方式来阅读。为了使它更简洁，你可以考虑更换take(1)与filter()，这将有同样的结果谓词功能first：

const optionOne$ = of('error')
    .pipe(
      first(setting => isSettingValid(setting))
    );

Answer 2

它应该像链来实现。随着即使你从INDEXDB获取数据上面的代码，你还是会最终使呼叫MangoDB（等待数据）。相反，使其复杂的，我做的是我将链中的电话。但它的一切都取决于使用情况。在这种情况下使用，我想链接的通话将更好地利用flatMap运营商。