feat(connectionState): The state of the connection can be accessed by…

… the promise on the ngStomp service

If you want to know if the system is connected or not, you can subscribe to the promise `ngStomp.connectionState.then()` and execute some code. `then` first function will be called if connection is up, `then` or `catch` will be called if connection is down.

Don't forget, if you set a long timeOut in setting, the promise won't be fulfilled until we reach this timeOut.

Linked to #43

core/service.js

@@ -16,31 +16,38 @@ export default class ngStompWebSocket {
         this.$timeout = $timeout;
         this.connections = [];
 
+        this.initConnectionState();
         this.connect();
     }
 
+    initConnectionState() {
+        this.deferred = this.$q.defer();
+        this.connectionState = this.deferred.promise;
+    }
+
     connect() {
         this.$setConnection();
+
         this.stompClient.connect(
             this.settings.login,
             this.settings.password,
-            () => {
-                this.deferred.resolve();
-            },
+            () => this.deferred.resolve(),
             () => {
                 this.deferred.reject();
+                this.initConnectionState();
                 this.settings.timeOut >= 0 && this.$timeout(() => {
                     this.connect();
                     this.$reconnectAll();
                 }, this.settings.timeOut);
             },
             this.settings.vhost
         );
-        return this.promiseResult;
+
+        return this.connectionState;
     }
 
     subscribe(queue, callback, header = {}, scope, json = false, digest) {
-        this.promiseResult
+        this.connectionState
             .then(
                 () => this.$stompSubscribe(queue, callback, header, scope, json, digest),
                 () => this.$$addToConnectionQueue({ queue, callback, header, scope, json, digest })
@@ -55,14 +62,14 @@ export default class ngStompWebSocket {
 
     /* Deprecated */
     unsubscribe(url) {
-        this.promiseResult.then(() => this.$stompUnSubscribe(url));
+        this.connectionState.then(() => this.$stompUnSubscribe(url));
         return this;
     }
 
     send(queue, data, header = {}) {
         let sendDeffered = this.$q.defer();
 
-        this.promiseResult.then(() => {
+        this.connectionState.then(() => {
             this.stompClient.send(queue, header, JSON.stringify(data));
             sendDeffered.resolve();
         });
@@ -110,8 +117,6 @@ export default class ngStompWebSocket {
             this.stompClient.heartbeat.outgoing = this.settings.heartbeat.outgoing;
             this.stompClient.heartbeat.incoming = this.settings.heartbeat.incoming;
         }
-        this.deferred = this.$q.defer();
-        this.promiseResult = this.deferred.promise;
     }
 
     $unRegisterScopeOnDestroy(connection) {

package.json

@@ -53,6 +53,7 @@
     "prebuild": "jspm install",
     "build": "gulp build",
     "release": "gulp release --type $(type)",
+    "postrelease": "npm publish",
     "test": "karma start --single-run",
     "test-tdd": "karma start"
   },