//create a subject

const mySubject = new Rx.Subject();

​

//add subscribers

const subscriberOne = mySubject.subscribe(val => {

  console.log('***SUBSCRIBER ONE***', val);

});

​

const subscriberTwo = mySubject.subscribe(val => {

  console.log('***SUBSCRIBER TWO***', val);

});

​

//publish values to observers of subject

mySubject.next('FIRST VALUE!');

mySubject.next('SECOND VALUE!');

​

//redux/ngrx-store has a concept of a dispatcher, or method to send actions to application

//lets extend Rx.Subject with our Dispatcher class to maintain familiar terms

​

//inherit from subject

class Dispatcher extends Rx.Subject{

  dispatch(value : any) : void {

    this.next(value);

  }

}

​

//create a dispatcher (just a Subject with wrapped next method)

const dispatcher = new Dispatcher();

​

//add subscribers

const subscriberOne = dispatcher.subscribe(val => {

  console.log('***SUBSCRIBER ONE***', val);

});

​

const subscriberTwo = dispatcher.subscribe(val => {

  console.log('***SUBSCRIBER TWO***', val);

});

​

//publish values to observers of dispatcher

dispatcher.dispatch('FIRST DISPATCHED VALUE!');

dispatcher.dispatch('SECOND DISPATCHED VALUE!');