diff --git a/src/ws/handler.js b/src/ws/handler.js index 17684f9..6d7d97e 100644 --- a/src/ws/handler.js +++ b/src/ws/handler.js @@ -68,8 +68,8 @@ const handleMsg = async (msg, id) => { } } -const fanoutMsg = async (channel, data) => { - Object.keys(connections).forEach((k) => { +const fanoutMsg = (channel, data) => { + Object.keys(connections).forEach( async (k) => { if (connections[k].events.indexOf(`${channel}:read`) !== -1) { const d = { event: `${channel}:read`,