stateContainer.js

stateContainer.js

import {Subject} from 'rx/Subject'
import {of} from 'rx/observable/of'
import {publishReplay, refCount, concat} from 'rxjs/observable'

function createState(initial) {
  const onChange$ = new Subject()

  function onChange(...args) {
    onChange$.next(args)
  }

  onChange.state$ = of(initial).pipe(
    concat(onChange$.asObservable()),
    publishReplay(1),
    refCount()
  )
  return onChange
}