Exrtact s State Stream from a redux store

rux.js

import { BehaviourSubject } from 'rx';


export function getStateStream(store) {
    const sub = new BehaviourSubject(store.getState());
    store.subscribe(state => sub.toNext(sub));
    return sub.asObservable();
}

new redux

import Rx from 'rxjs'
import $$observable from 'symbol-observable'

export default function observableFromStore(store) {
  const store$ = new Rx.BehaviorSubject(store.getState())

  const observableSubscribe = store[$$observable]()
  observableSubscribe.subscribe(store$)

  return store$
}