promise - 不发送任何新 Action 的 redux-observable 史诗

Question

可能是我是一个菜鸟，还没有完全理解这些东西应该如何工作，但是我在 redux-observable 中有一个史诗，我想用它作为一种方式来创建一个 promise ，它将调度一个 Action 并等待一个解决之前的不同操作。我通过将操作映射到 '__IGNORE__' 来使其工作但我真的不想那样做。有没有办法让史诗处理一个 Action ，而不传递其他任何东西？

这是我的代码:

export const waitFor = (type, action) => new Promise((resolve, reject) => {
   const waitForResult = action$ => action$.ofType(type).do(() => resolve()).mapTo({type: "___IGNORE___"});
   registerEpic(waitForResult);

   action();
 });

Answer 1

您可以使用 .ignoreElements() 从可观察链中丢弃任何下一个值。 RxJS 运算符

action$.ofType(type)
  .do(() => resolve())
  .ignoreElements();

这样做的另一种方法(不再是对或错)是创建一个仅订阅的匿名 Observable。

const waitForResultEpic = action$ => new Observable(observer =>
  action$.ofType(type)
    .subscribe(() => resolve())
);

这隐式返回我们创建的订阅，因此它也附加到我们的 rootEpic 的生命周期。因为我们从不打电话 observer.next() ，这个史诗从不发出任何值；就像 ignoreElements() .

尽管您没有询问，但您最终可能会注意到您的史诗将永远运行，监听与 type 匹配的传入 Action 。多变的。这可能不是您想要的，如果您想匹配一次然后完成。

您可以使用 .take(1) 来实现这一点。运算符(operator)。

const waitForResult = action$ =>
  action$.ofType(type)
    .take(1)
    .do(() => resolve())
    .ignoreElements();

或者

const waitForResult = action$ => new Observable(observer =>
  action$.ofType(type)
    .take(1)
    .subscribe({
      next: () => resolve(),
      error: err => observer.error(err),
      complete: () => observer.complete()
    })
);

这在每个应用程序的生命周期内只会匹配一次——一旦收到，它就永远不会再匹配了。