diff --git a/src/ws/handler.js b/src/ws/handler.js
index 6d7d97e..4afe418 100644
--- a/src/ws/handler.js
+++ b/src/ws/handler.js
@@ -76,13 +76,14 @@ const fanoutMsg = (channel, data) => {
         data,
       }
       connections[k].connection.send(JSON.stringify(d))
-    } else if (connections[k].events.indexOf('streams:full') !== -1) {
-      const m = await crud['streams'].getAllPop()
-      const d = {
-        event: 'streams:full',
-        data: m,
+      if (connections[k].events.indexOf('streams:full') !== -1) {
+        const m = await crud['streams'].getAllPop()
+        const d = {
+          event: 'streams:full',
+          data: m,
+        }
+        connections[k].connection.send(JSON.stringify(d))
       }
-      connections[k].connection.send(JSON.stringify(d))
     }
   })
 }