javascript - redux-observable 中的独立链取消？

Question

我是 RxJS 的新手。在我的应用程序中，我需要独立取消延迟操作。 Here's一个工作示例(延迟为 3 秒)。但是当我选择删除多个项目并取消其中一个时，然后一次全部取消。

史诗代码:

const itemsEpic = action$ =>
  action$.ofType('WILL_DELETE')
    .flatMap(action =>
      Observable.of({type: 'DELETE', id: action.id})
        .delay(3000)
        .takeUntil(action$.ofType('UNDO_DELETE'))
  )

我想我需要将 id 传递给 takeUntil 运算符，但我不知道该怎么做。

Answer 1

如果我正确理解了 takeUntil 运算符，一旦参数 Observable 发出，它就会停止从它被调用的 Observable 发出新的项目这是第一项。考虑到这一点，您可以这样做:

const itemsEpic = action$ => action$.ofType('WILL_DELETE')
  .flatMap(action => Observable.of({ type: 'DELETE', id: action.id })
    .delay(3000)
    .takeUntil(action$.ofType('UNDO_DELETE').filter(({id}) => id === action.id))
  )