Reject outstanding RPC calls when the connection closes

Author: davidwdan

bower.json

@@ -1,6 +1,6 @@
 {
     "name": "angular-wamp",
-    "version": "0.1.7",
+    "version": "0.1.8",
     "main": "./release/angular-wamp.js",
     "authors": [
         "David Dan <[email protected]>"

package.json

@@ -1,7 +1,7 @@
 {
   "name": "angular-wamp",
   "description": "Angular library for Autobahn.js (WAMP v2)",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "author": "David Dan <[email protected]>",
   "homepage": "https://github.com/voryx/angular-wamp",
   "repository": {

release/angular-wamp.js

@@ -244,8 +244,16 @@ if (typeof module !== "undefined" && typeof exports !== "undefined" && module.ex
 
             connection.onclose = digestWrapper(function (reason, details) {
                 $log.debug("Connection Closed: ", reason, details);
-                sessionDeferred = $q.defer();
-                sessionPromise = sessionDeferred.promise;
+
+                //Reject outstanding RPC calls
+                for (var key in connection.session._call_reqs) {
+                    if (connection.session._call_reqs.hasOwnProperty(key)) {
+                        var error = new Error("Connection Closed");
+                        var call = connection.session._call_reqs[key];
+                        call[0].reject(error);
+                    }
+                }
+
                 $rootScope.$broadcast("$wamp.close", {reason: reason, details: details});
             });
 

release/angular-wamp.min.js

@@ -244,8 +244,16 @@ if (typeof module !== "undefined" && typeof exports !== "undefined" && module.ex
 
             connection.onclose = digestWrapper(function (reason, details) {
                 $log.debug("Connection Closed: ", reason, details);
-                sessionDeferred = $q.defer();
-                sessionPromise = sessionDeferred.promise;
+
+                //Reject outstanding RPC calls
+                for (var key in connection.session._call_reqs) {
+                    if (connection.session._call_reqs.hasOwnProperty(key)) {
+                        var error = new Error("Connection Closed");
+                        var call = connection.session._call_reqs[key];
+                        call[0].reject(error);
+                    }
+                }
+
                 $rootScope.$broadcast("$wamp.close", {reason: reason, details: details});
             });