Stores in Flux with Rx.js

import ACTION_CONSTANTS from '../../constant/action-constants';
import Rx from 'rx';

class SomeStore {
  constructor(dispatcher) {
    'ngInject';
    
    this.dispatcher = dispatcher;
    this.someState = false;
    this.subject = new Rx.ReplaySubject(1);
    this.registerActionHandlers();
  }
  
  registerActionHandlers() {
    this.dispatcher
      .filter((action) => action === ACTION_CONSTANTS.SOME_ACTION)
      .subscribe(() => this.changeSomeState());
  }

  changeSomeState() {
    this.someState = !this.someState;
    this.emitChange();
  }
  
  emitChange() {
    this.subject.onNext(this.someState);
  }
}

export default SomeStore;