ObservableStore

const store = new ObservableStore(initState)
store.subscribe(function showValue(value) {
  console.log('saw value:', value)
})
 
store.putState(5) // "saw value: 5"
store.putState(true) // "saw value: true"
store.putState({ hello: 'world' }) // "saw value: { hello: 'world' }"
 
console.log(store.getState().hello) // "world"

const pipe = require('pump')
const asStream = require('obs-store/lib/asStream')
 
const storeOne = new ObservableStore(initState)
const storeTwo = new ObservableStore()
 
pipe(
  asStream(storeOne),
  transformStream,
  asStream(storeTwo)
)