循环一定次数

Question

我有一个动作，它的有效载荷为.times。我想循环这么多次，我这样做了：

function upAsyncEpic(action$: Observable<Action>, state$: StateObservable<State>): Observable<Action> {
    return action$.pipe(
        ofType(UP_ASYNC),
        delay(1000),
        mapTo(up())
    );
}

这不会循环它只会发生一次。我希望它循环“延迟”然后“mapTo”action.times 次。我试过这个：

    return action$.pipe(
        ofType(UP_ASYNC),
        repeat(action => action.times),
        delay(1000),
        mapTo(up())
    );

但这不起作用。超级全新的 redux-observables，刚刚学习。

基本上我想要的是如果有人发送动作{ type: 'UP_ASYNC', times: 5 } 应该发生的是这样的：

            delay(1000),
            mapTo(up())
            delay(1000),
            mapTo(up())
            delay(1000),
            mapTo(up())
            delay(1000),
            mapTo(up())
            delay(1000),
            mapTo(up())

Answer 1

问题：repeat() 将整数作为参数来重复计数。

签名：

repeat(count: number): Observable。 Documentation.

Example 来自 learnrxjs

您的示例将如下所示：

function upAsyncEpic(
  action$: Observable<Action>,
  state$: StateObservable<State>
): Observable<Action> {
  let count = 0;

  const source = action$.pipe(
    ofType(UP_ASYNC),
    map(({ times }) => {
      count = times;
    }),
    delay(1000),
    mapTo(up())
  );

  return source.pipe(repeat(count));
}