How to use Rx.Observable in-place of Redux store

observable-store.js

import update from 'react/lib/update'
import { Observable, Subject, ReplaySubject } from 'rx'

const INITIAL_STATE = {
  user: null
}

const updates = new ReplaySubject()
export const state = Observable.of(INITIAL_STATE)
  .merge(updates.map(change => state => update(state, change)))
  .scan((state, reducer) => reducer(state))
  .shareReplay(16)

export const subscribe = (path, fn) => state.pluck(path).subscribe(fn)
export const dispatch = (change) => updates.onNext(change)

// Usage
// dispatch({ user: { $set: { name: "Some user" } }})
// subscribe('user', user => this.setState({ user })
// propsToState replacement
// state.pluck(['user', 'selection'])