Ayush Mukherjee 4 years ago
parent 487f97e7e5
commit b7856fa42c

@ -77,9 +77,10 @@ const fanoutMsg = (channel, data) => {
} }
connections[k].connection.send(JSON.stringify(d)) connections[k].connection.send(JSON.stringify(d))
} else if (connections[k].events.indexOf('streams:full') !== -1) { } else if (connections[k].events.indexOf('streams:full') !== -1) {
const m = await crud['streams'].getAllPop()
const d = { const d = {
event: 'streams:full', event: 'streams:full',
data: await crud['streams'].getAllPop(), data: m,
} }
connections[k].connection.send(JSON.stringify(d)) connections[k].connection.send(JSON.stringify(d))
} }

Loading…
Cancel
Save