javascript - 将代码从 Rxjs 转换为 xstream

Question

相当于什么

return Rx.Observable.merge([deleteTodo$, addTodo$, completeTodo$]).startWith([])
  .scan(function (currentTodos, modifier) { return modifier(currentTodos); });

以上在rxjs中xstream？

Answer 1

应该是这样的。初始值作为函数后的第二个参数包含。

xs.merge(deleteTodo$, addTodo$, completeTodo$) .fold(function (currentTodos, modifier) { return modifier(currentTodos); }, [])