[Version] added override to $sub method

Author: sqlProvider

README.md

@@ -40,7 +40,8 @@ bootstrap: [RootComponent]
 declare class PubSubService{
 	private events: Object;
 	$pub(event: string, eventObject?: any): void;
-	$sub(event: string): <Observable<number>>;
+	$sub(event: string): <Observable<any>>;
+	$sub(event: string, callback: (value: any) => void, error?: (error: any) => void, complete?: () => void): Subscription;
 }
 ```
 
@@ -59,7 +60,7 @@ export class OverlayComponent implements OnInit, OnDestroy {
 }
 ```
 
-#### PubSubService.$sub(event: stirng): Observable<number>
+#### PubSubService.$sub(event: stirng): Observable<any>
 
 Subscribe to channel. 
 
@@ -71,12 +72,19 @@ export class NavigationComponent implements OnInit, OnDestroy {
 	constructor(private pubsub: EventDispatcherService) { }
 
 	ngOnInit() {
+		// usage of $sub(event: string): <Observable<any>>;
 		this.closeSidenavSub = this.pubsub.$sub('pleaseCloseSidenav').subscribe((from) => {
 			from ? this.sidenavOpened = false : void 0
 		});
+
+		// usage of $sub(event: string, callback: (value: any) => void, error?: (error: any) => void, complete?: () => void): Subscription;
+		this.openSidenavSub = this.pubsub.$sub('pleaseOpenSidenav', (from) => {
+			from ? this.sidenavOpened = false : void 0
+		});
 	}
 	ngOnDestroy() {
 		this.closeSidenavSub.unsubscribe();
+		this.openSidenavSub.unsubscribe();
 	}
 ```
 

angular2-pubsub.service.ts

@@ -8,16 +8,18 @@ export class PubSubService {
 
 	constructor() { }
 
-	$sub(event: string) {
+	$sub(event: string, callback: (value: any) => void, error?: (error: any) => void, complete?: () => void) {
 		if (event == undefined) { 
 			console.warn('[PubSub Service] => Subscription method must get event name.');
 			return;
 		};
 
 		if (this.events[event] === undefined)
-			this.events[event] = new BehaviorSubject<number>(0);
-		
-		return <Observable<number>>this.events[event].asObservable();
+			this.events[event] = new BehaviorSubject<any>(0);
+		if (!callback || typeof callback !== 'function')
+			return <Observable<any>>this.events[event].asObservable();
+		else	
+			return (<Observable<any>>this.events[event].asObservable()).subscribe(callback, error, complete);
 	}
 	$pub(event: string, eventObject?: any) {
 		if (event == undefined) {

bower.json

@@ -1,6 +1,7 @@
 {
   "name": "angular2-pubsub",
   "description": "Pub/Sub service for Angular 2",
+  "version": "1.1.0",
   "main": "",
   "authors": [
     "Semih KEŞKEK"

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "angular2-pubsub",
-	"version": "1.0.0",
+	"version": "1.1.0",
 	"description": "Pub/Sub service for Angular 2",
 	"repository": {
 		"type": "git",

tsconfig.json

@@ -0,0 +1,6 @@
+{
+    "compilerOptions": {
+        "target": "ES6",
+		"experimentalDecorators": true
+    }
+}