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