Are you able to call subs.subscribe("mySub").stop() ? kadirahq#28

markshust · Aug 2, 2016 · d228036 · d228036
1 parent 305cf5c
commit d228036
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/lib/sub_manager.js b/lib/sub_manager.js
@@ -23,9 +23,10 @@ SubsManager.prototype.subscribe = function() {
   var self = this;
   if(Meteor.isClient) {
     var args = _.toArray(arguments);
-    this._addSub(args);
+    var key = this._addSub(args);
 
     return {
+      key: key,
       ready: function() {
         self.dep.depend();
         return self._ready;
@@ -81,6 +82,21 @@ SubsManager.prototype._addSub = function(args) {
   var index = _.indexOf(self._cacheList, sub);
   self._cacheList.splice(index, 1);
   self._cacheList.push(sub);
+
+  return hash;
+};
+
+SubsManager.prototype.unsubscribe = function(subKey) {
+  var sub = this._cacheMap[subKey];
+  var index = _.indexOf(this._cacheList, sub);
+
+  if (!sub || index == -1) {
+    return;
+  }
+
+  this._cacheList.splice(index, 1);
+  delete this._cacheMap[subKey];
+  this._reRunSubs();
 };
 
 SubsManager.prototype._reRunSubs = function() {