rxjs-react

const subject$ = new Rx.Subject();
const bindAction = (action) => (...args) => subject$.next(action(args));

const doSomething = () => ({ type: 'DO_SOMETHING' })

const doSomethingAsyncComplete = () => {
  return {
    type: 'DO_SOMETHING_COMPLETE'
  }
}

const doSomethingAsync = bindAction(() => {
  subject$.next(doSomething());
  
  setTimeout(() => {
    subject$.next(doSomethingAsyncComplete());
  }, 500)
});

const App = (props) => <button onClick={doSomethingAsync}>App</button>

subject$
  .startWith('boo')
  .scan((state, action) => {
    if(!action) return state;
    return state
  })
  .subscribe((state) => {
    console.log(state);
    ReactDOM.render(<App/>, document.getElementById('mount'))
  })

f