javascript - 带 promise 的条件可观察调用

Question

我正在尝试用 observable 做一些没有技能的事情:)我有类似的东西(伪代码):

someobservable$.pipe(
  mergeMap(param1 => {
    const condition = await promise;
    return condition ? return EMPTY : return of(param1);
  ),
  mergeMap(param1 => do some stuff)
);

所以，我要做的是，如果第一个 mergeMap 中的条件为 true，则不要转到第二个 mergeMap。这段代码似乎有效。但是如何在第一个 mergeMap 中调用并等待 Promise？还是这种方法根本就是错误的？

Answer 1

如果您选择完整的 RX 方式，则不需要使用等待

someobservable$.pipe(
  mergeMap(param1 =>  
        from(promise).pipe(filter(condition=>condition),mapTo(param1))
  ),
);