idk

4 years ago · 5ca90f131a
parent 2faced9d43
commit 5ca90f131a
1 changed files with 2 additions and 2 deletions
--- a/src/ws/handler.js
+++ b/src/ws/handler.js
@ -68,8 +68,8 @@ const handleMsg = async (msg, id) => {
  }
 }
-const fanoutMsg = async (channel, data) => {
+const fanoutMsg = (channel, data) => {
-  Object.keys(connections).forEach((k) => {
+  Object.keys(connections).forEach( async (k) => {
    if (connections[k].events.indexOf(`${channel}:read`) !== -1) {
      const d = {
        event: `${channel}:read`,