在 redux-observable 中使用 rxjs 示例来监听其他操作

Question

我使用 redux-observable 作为调度动作和存储之间的中间件。我正在尝试使用 rxjs sample 函数来完成此操作，但不幸的是它对我不起作用。这是我的史诗：

export const inviteUserEpic = (action$) => {
    return action$.ofType(a.INVITE_USER)
    .flatMap(({ body }) => {
        return Observable.concat(
            Observable.of({ type: authActions.REGISTER_REQ, body }),
            Observable.of(push(`/team/${body.teamId}`))
            .sample(action$.ofType(authActions.REGISTER_SUCCESS))
        );
    });
};

基本上这个想法是有多个地方可以注册一个新用户，在这种情况下，我想在成功注册用户后重定向到团队页面。我看到 REGISTER_REQ 发出，它随后会发出 REGISTER_SUCCESS。但是重定向 observable 永远不会被采样。

Answer 1

这是因为sample 运算符仅在源本身仍处于活动状态时才处于活动状态并订阅通知程序。在这种情况下，源是Observable.of()，它将发出提供的操作，然后立即发出complete()，这意味着您将不再采样任何东西——在您的REGISTER_SUCCESS 操作被调度之前，它已经是complete()。即.sample() 不会阻止可观察链完成。

相反，您需要首先匹配预期的操作，然后在匹配时将其映射到您的push()。您可能还想只听一次REQUEST_SUCESS，而不是无限期地听，所以您需要添加一个.take(1)

action$.ofType(authActions.REGISTER_SUCCESS)
  .take(1)
  .map(() => push(`/team/${body.teamId}`))

把它和你现有的 Epic 放在一起

export const inviteUserEpic = (action$) => {
    return action$.ofType(a.INVITE_USER)
    .flatMap(({ body }) => {
        return Observable.concat(
            Observable.of({ type: authActions.REGISTER_REQ, body }),
            action$.ofType(authActions.REGISTER_SUCCESS)
              .take(1)
              .map(() => push(`/team/${body.teamId}`))
        );
    });
};

你可以在这里看到一个工作示例：http://jsbin.com/sonuqob/edit?js,output