fix leak on duplicate subscription - share#260

dcharbonnier · dcharbonnier · commit 41c40f6416dc · 2018-11-30T13:45:21.000+01:00
diff --git a/lib/agent.js b/lib/agent.js
@@ -105,7 +105,7 @@ Agent.prototype._subscribeToStream = function(collection, id, stream) {
   stream.on('end', function() {
     // The op stream is done sending, so release its reference
     var streams = agent.subscribedDocs[collection];
-    if (!streams) return;
+    if (!streams || streams[id] !== stream) return;
     delete streams[id];
     if (util.hasKeys(streams)) return;
     delete agent.subscribedDocs[collection];
