Merge pull request #4 from dustincleveland/master

Fix #3 and Tests

Author: Semih KEŞKEK

src/angular2-pubsub.service.spec.ts

@@ -12,7 +12,7 @@ describe('PubSubService', (): void => {
 
     describe('$sub', (): void => {
         it('should throw an error when event is falsy', (): void => {
-            expect(pubService.$sub.bind(undefined)).toThrow();
+            expect(() => pubService.$sub(undefined)).toThrow();
         });
 
         it('should return an observable when there is no callback', (): void => {
@@ -30,11 +30,11 @@ describe('PubSubService', (): void => {
 
     describe('$pub', (): void => {
         it('should throw an error when event is falsy', (): void => {
-            expect(pubService.$pub.bind(undefined)).toThrow();
+            expect(() => pubService.$pub(undefined)).toThrow();
         });
 
-        it('should throw an error when event is not registered', (): void => {
-            expect(pubService.$pub.bind('not-registered')).toThrow();
+        it('should do nothing when an event is not registered', (): void => {
+            expect(() => pubService.$pub('not-registered')).not.toThrow();
         });
 
         it('should publish with parameters if the event is registered', (): void => {

src/angular2-pubsub.service.ts

@@ -1,5 +1,5 @@
 import { Injectable } from '@angular/core';
-import { BehaviorSubject } from 'rxjs/BehaviorSubject';
+import { ReplaySubject } from 'rxjs/ReplaySubject';
 import { Observable } from 'rxjs/Observable';
 import { Subscription } from 'rxjs/Subscription';
 
@@ -21,7 +21,7 @@ export class PubSubService implements IPubSubService {
 		}
 
 		if (this.events[event] === undefined) {
-			this.events[event] = new BehaviorSubject<any>(0);
+			this.events[event] = new ReplaySubject<any>();
 		}
 
 		if (typeof callback !== 'function') {
@@ -35,7 +35,7 @@ export class PubSubService implements IPubSubService {
 		if (!event) {
 			throw new Error(`[${ServiceName}] => Publish method must get event name.`);
 		} else if (!this.events[event]) {
-			throw new Error(`[${ServiceName}] => No recorded events found for ${event}.`);
+			return;
 		}
 
 		this.events[event].next(eventObject);