Redux pattern with RxJS

redux-rx.js

const Rx = require('rx')
const action$ = new Rx.Subject()
const initState = 0

const reducer = (state, action) => {
    switch (action.type) {
        case 'INC':
            return state + action.payload
        default:
            return state
    }
}

const store$ = action$
    .startWith(initState)
    .scan(reducer)

const dispatcher = (func) => (...args) => {
    action$.onNext(func(...args))
}

const inc = dispatcher((payload) => ({
    type: 'INC',
    payload
}));

store$.subscribe((state) => {
    console.log(state)
})

setInterval(() => {
    inc(1)
}, 1000)