refactor(models): use Rx ReplaySubject

Author: PatrickJS

src/app/models/CounterModel.ts

@@ -1,5 +1,7 @@
-import {Observable, EventEmitter} from 'angular2/src/facade/async';
+// import {Observable, EventEmitter} from 'angular2/src/facade/async';
 import {bind, Inject, Injectable} from 'angular2/di';
+import * as Rx from 'rx';
+var {Observable, ReplaySubject} = Rx;
 
 import {CounterIntent} from '../intents/CounterIntent';
 
@@ -12,39 +14,31 @@ var _initialState:IState = {
 };
 
 
-interface IObservable {
-  next(val:any)
-  return(val:any)
-  throw(val:any)
-  observer(generator: any): Observable;
-}
-
 @Injectable()
 export class CounterModel {
-  public  subject: Observable = new EventEmitter();
+  public  subject: any = new ReplaySubject(1);
   private _state: IState;
   constructor(
     @Inject(CounterIntent) intent, @Inject('counterState') state) {
     console.log('CounterMODEL');
-    this._state  = state;
+    this._state = state;
 
-    var {
-      incrementCounterSubject
-    } = intent.subjects;
+    var {incrementCounterSubject} = intent.subjects;
 
     incrementCounterSubject.observer({
       next: this.incrementCounter.bind(this)
     });
 
+    this.subject.onNext(state);
   }
 
   incrementCounter() {
     var counter = this._state.counter;
     var state = Object.assign({}, this._state, {
       counter: counter + 1
     });
-    this._state = state;
-    this.subject.next(state);
+    this._state = state; // store prevous state until I find a better way
+    this.subject.onNext(state);
   }
 }
 

src/app/models/GreetModel.ts

@@ -1,5 +1,8 @@
-import {Observable, EventEmitter} from 'angular2/src/facade/async';
+// import {Observable, EventEmitter} from 'angular2/src/facade/async';
 import {bind, Inject, Injectable} from 'angular2/di';
+import * as Rx from 'rx';
+var {Observable, ReplaySubject} = Rx;
+
 
 import {GreetIntent} from '../intents/GreetIntent';
 
@@ -16,30 +19,30 @@ var _initialState:IState = {
 
 @Injectable()
 export class GreetModel {
-  public  subject: Observable = new EventEmitter();
+  public  subject: any = new ReplaySubject(1);
   private _state: IState;
   constructor(
     @Inject(GreetIntent) intent, @Inject('greetState') state) {
     console.log('GreetMODEL');
     this._state  = state;
 
-    var {
-      toggleGreetSubject
-    } = intent.subjects;
+    var {toggleGreetSubject} = intent.subjects;
 
     toggleGreetSubject.observer({
       next: this.toggleGreet.bind(this)
     });
 
+
+    this.subject.onNext(this._state);
   }
 
-  toggleGreet() {
+  toggleGreet(subject) {
     var greet = this._state.greeting;
     var state = Object.assign({}, this._state, {
       greeting: greet === greet1 ? greet2 : greet1
     });
-    this._state = state;
-    this.subject.next(state);
+    this._state = state; // store prevous state until I find a better way
+    this.subject.onNext(state);
   }
 }