Creates stream of states from a Redux store

streamFromStore.js

import xs from 'xstream'

function streamFromStore(store) {
  return xs.create(
    {
      start: function(listener){
        this.unsubscribe = store.subscribe(() => listener.next(store.getState()))
      },
      stop: function(){
        this.unsubscribe()
      }
    }
  ).startWith(store.getState())
}