Merge pull request #36 from KrisSiegel/2.4.1

Expose subscriber count

msngr.js

@@ -18,7 +18,7 @@ var msngr = msngr || (function() {
         return internal.objects.message(topic, category, subcategory);
     };
 
-    external.version = "2.4.0";
+    external.version = "2.4.1";
 
     // Merge two inputs into one
     var twoMerge = function(input1, input2) {
@@ -1017,6 +1017,13 @@ msngr.extend((function(external, internal) {
             }
         });
 
+        // Setup a property to get subscribers
+        Object.defineProperty(msgObj, "subscribers", {
+            get: function() {
+                return messageIndex.query(msg).length;
+            }
+        });
+
         // If debug mode is enabled then let's expose the internal method hit counts.
         // These counts are only good if a method is called and succeeds.
         if (external.debug === true) {

package.json

@@ -2,7 +2,7 @@
     "name": "msngr",
     "main": "msngr.js",
     "description": "msngr.js is a small library used to facilitate communication through messages rather than direct binding. This loose coupling allows connecting components to each other or to UI components in an abstract way on the server or the client.",
-    "version": "2.4.0",
+    "version": "2.4.1",
     "keywords": ["message", "messaging", "subscription", "delegation", "eventing", "dom", "binding"],
     "repository": {
         "type": "git",

src/main.js

@@ -18,7 +18,7 @@ var msngr = msngr || (function() {
         return internal.objects.message(topic, category, subcategory);
     };
 
-    external.version = "2.4.0";
+    external.version = "2.4.1";
 
     // Merge two inputs into one
     var twoMerge = function(input1, input2) {

src/objects/message.aspec.js

@@ -451,6 +451,17 @@ describe("./objects/message.js", function() {
         msngr.debug = false;
         var msg2 = msngr("another");
         expect(msg2.counts).to.not.exist;
+
+        msngr.debug = true;
+    });
+
+    it("msngr().subscribers - returns a correct subscriber count", function() {
+        var msg = msngr("test", "whateves");
+        expect(msg.subscribers).to.equal(0);
+        msg.on(function() { });
+        expect(msg.subscribers).to.equal(1);
+        msg.dropAll();
+        expect(msg.subscribers).to.equal(0);
     });
 
 });

src/objects/message.js

@@ -337,6 +337,13 @@ msngr.extend((function(external, internal) {
             }
         });
 
+        // Setup a property to get subscribers
+        Object.defineProperty(msgObj, "subscribers", {
+            get: function() {
+                return messageIndex.query(msg).length;
+            }
+        });
+
         // If debug mode is enabled then let's expose the internal method hit counts.
         // These counts are only good if a method is called and succeeds.
         if (external.debug === true) {