diff --git a/src/ws/handler.js b/src/ws/handler.js index 6f5a1b7..4c5742c 100644 --- a/src/ws/handler.js +++ b/src/ws/handler.js @@ -77,9 +77,10 @@ const fanoutMsg = (channel, 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: await crud['streams'].getAllPop(), + data: m, } connections[k].connection.send(JSON.stringify(d)) }