Remove _ from subs

davedoesdev · Nov 29, 2016 · fe2ce35 · fe2ce35
1 parent 8503574
commit fe2ce35
Show file tree

Hide file tree

Showing 10 changed files with 23 additions and 23 deletions.
diff --git a/coverage/coverage.json b/coverage/coverage.json
diff --git a/coverage/lcov-report/index.html b/coverage/lcov-report/index.html
@@ -90,7 +90,7 @@ <h1>
 </div><!-- /wrapper -->
 <div class='footer quiet pad2 space-top1 center small'>
   Code coverage
-  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 07:39:28 GMT+0000 (GMT)
+  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 21:50:16 GMT+0000 (GMT)
 </div>
 </div>
 <script src="prettify.js"></script>

diff --git a/coverage/lcov-report/mqlobber/index.html b/coverage/lcov-report/mqlobber/index.html
@@ -77,7 +77,7 @@ <h1>
 </div><!-- /wrapper -->
 <div class='footer quiet pad2 space-top1 center small'>
   Code coverage
-  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 07:39:28 GMT+0000 (GMT)
+  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 21:50:16 GMT+0000 (GMT)
 </div>
 </div>
 <script src="../prettify.js"></script>

diff --git a/coverage/lcov-report/mqlobber/index.js.html b/coverage/lcov-report/mqlobber/index.js.html
@@ -61,7 +61,7 @@ <h1>
 </div><!-- /wrapper -->
 <div class='footer quiet pad2 space-top1 center small'>
   Code coverage
-  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 07:39:28 GMT+0000 (GMT)
+  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 21:50:16 GMT+0000 (GMT)
 </div>
 </div>
 <script src="../prettify.js"></script>

diff --git a/coverage/lcov-report/mqlobber/lib/client.js.html b/coverage/lcov-report/mqlobber/lib/client.js.html
@@ -2311,7 +2311,7 @@ <h1>
 </div><!-- /wrapper -->
 <div class='footer quiet pad2 space-top1 center small'>
   Code coverage
-  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 07:39:28 GMT+0000 (GMT)
+  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 21:50:16 GMT+0000 (GMT)
 </div>
 </div>
 <script src="../../prettify.js"></script>

diff --git a/coverage/lcov-report/mqlobber/lib/index.html b/coverage/lcov-report/mqlobber/lib/index.html
@@ -90,7 +90,7 @@ <h1>
 </div><!-- /wrapper -->
 <div class='footer quiet pad2 space-top1 center small'>
   Code coverage
-  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 07:39:28 GMT+0000 (GMT)
+  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 21:50:16 GMT+0000 (GMT)
 </div>
 </div>
 <script src="../../prettify.js"></script>

diff --git a/coverage/lcov-report/mqlobber/lib/server.js.html b/coverage/lcov-report/mqlobber/lib/server.js.html
@@ -1092,7 +1092,7 @@ <h1>
     options = options || {};
 &nbsp;
     this.fsq = fsq;
-    this._subs = new Set();
+    this.subs = new Set();
     this._done = false;
     this.mux = new BPMux(stream, util._extend(util._extend({}, options),
                {
@@ -1458,13 +1458,13 @@ <h1>
         }
     }
 &nbsp;
-    if (!this._done &amp;&amp; !this._subs.has(topic))
+    if (!this._done &amp;&amp; !this.subs.has(topic))
     {
         this.fsq.subscribe(topic, this.handler, options, function (err)
         {
             if (!err)
             {
-                ths._subs.add(topic);
+                ths.subs.add(topic);
             }
             cb2(err);
         });
@@ -1520,15 +1520,15 @@ <h1>
                 }
                 else
                 {
-                    ths._subs.delete(t);
+                    ths.subs.delete(t);
                     process.nextTick(next);
                 }
             });
         },
 &nbsp;
         next = function ()
         {
-            for (var t of ths._subs)
+            for (var t of ths.subs)
             {
                 return unsub(t);
             }
@@ -1537,13 +1537,13 @@ <h1>
 &nbsp;
         next();
     }
-    else if (this._subs.has(topic))
+    else if (this.subs.has(topic))
     {
         this.fsq.unsubscribe(topic, this.handler, function (err)
         {
             if (!err)
             {
-                ths._subs.delete(topic);
+                ths.subs.delete(topic);
             }
             cb2(err);
         });
@@ -1561,7 +1561,7 @@ <h1>
 </div><!-- /wrapper -->
 <div class='footer quiet pad2 space-top1 center small'>
   Code coverage
-  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 07:39:28 GMT+0000 (GMT)
+  generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Nov 29 2016 21:50:16 GMT+0000 (GMT)
 </div>
 </div>
 <script src="../../prettify.js"></script>

diff --git a/lib/server.js b/lib/server.js
@@ -39,7 +39,7 @@ function MQlobberServer(fsq, stream, options)
     options = options || {};
 
     this.fsq = fsq;
-    this._subs = new Set();
+    this.subs = new Set();
     this._done = false;
     this.mux = new BPMux(stream, util._extend(util._extend({}, options),
                {
@@ -405,13 +405,13 @@ MQlobberServer.prototype.subscribe = function (topic, options, cb)
         }
     }
 
-    if (!this._done && !this._subs.has(topic))
+    if (!this._done && !this.subs.has(topic))
     {
         this.fsq.subscribe(topic, this.handler, options, function (err)
         {
             if (!err)
             {
-                ths._subs.add(topic);
+                ths.subs.add(topic);
             }
             cb2(err);
         });
@@ -467,15 +467,15 @@ MQlobberServer.prototype.unsubscribe = function (topic, cb)
                 }
                 else
                 {
-                    ths._subs.delete(t);
+                    ths.subs.delete(t);
                     process.nextTick(next);
                 }
             });
         },
 
         next = function ()
         {
-            for (var t of ths._subs)
+            for (var t of ths.subs)
             {
                 return unsub(t);
             }
@@ -484,13 +484,13 @@ MQlobberServer.prototype.unsubscribe = function (topic, cb)
 
         next();
     }
-    else if (this._subs.has(topic))
+    else if (this.subs.has(topic))
     {
         this.fsq.unsubscribe(topic, this.handler, function (err)
         {
             if (!err)
             {
-                ths._subs.delete(topic);
+                ths.subs.delete(topic);
             }
             cb2(err);
         });

diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "mqlobber",
   "description": "Streaming message queue with pub-sub, work queues, wildcards and back-pressure. Just Node and a filesystem required.",
-  "version": "2.7.0",
+  "version": "2.8.0",
   "homepage": "https://github.com/davedoesdev/mqlobber",
   "author": {
     "name": "David Halls",

diff --git a/test/runner.js b/test/runner.js
@@ -1756,7 +1756,7 @@ describe(type, function ()
     with_mqs(1, 'server should callback without error when unsubscribing from topic not subscribed to',
     function (mqs, cb)
     {
-        expect(mqs[0].server._subs.has('foo')).to.equal(false);
+        expect(mqs[0].server.subs.has('foo')).to.equal(false);
         mqs[0].server.unsubscribe('foo', cb);
     });