Support exclude stream in getStreamsByTag

lsm · Apr 13, 2016 · 58db750 · 58db750
1 parent 72de008
commit 58db750
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/socket/tag.js b/lib/socket/tag.js
@@ -50,11 +50,12 @@ exports.hasTag = function(tag, stream) {
     return this.streams.some(check)
 }
 
-exports.getStreamsByTag = function(tag, streams) {
+exports.getStreamsByTag = function(tag, streams, excluding) {
   return (streams || this.streams).filter(function(stream) {
     var tags = stream.__smq_tags__
     return Array.isArray(tags)
       && tags.indexOf(tag) > -1
+      && stream !== excluding
   })
 }