Преобразование кода из 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); }, [])