fix broadcast

manix · May 31, 2019 · d32c4a0 · d32c4a0
1 parent dd04c60
commit d32c4a0
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "websocket-base",
-  "version": "4.0.0",
+  "version": "4.0.1",
   "description": "A websocket server foundation.",
   "main": "src/server.js",
   "scripts": {

diff --git a/src/store-events.js b/src/store-events.js
@@ -4,9 +4,10 @@ module.exports = function (store) {
   let base = require("./server");
 
   store.subscribe("/base/broadcast", function (message) {
-    for (let user of base.users.all()) {
-      user.send(message);
-    }
+    let users = base.users.all();
+    Object.keys(users).forEach(key => {
+      users[key].send(message);
+    });
   });
 
   store.subscribe("/base/conn-open", function (message) {