diff --git a/services/real-time/app/coffee/DrainManager.coffee b/services/real-time/app/coffee/DrainManager.coffee index a71ffa8ed9..2219291267 100644 --- a/services/real-time/app/coffee/DrainManager.coffee +++ b/services/real-time/app/coffee/DrainManager.coffee @@ -4,7 +4,7 @@ module.exports = DrainManager = startDrainTimeWindow: (io, minsToDrain)-> drainPerMin = io.sockets.clients().length / minsToDrain - DrainManager.startDrain(io, drainPerMin / 60) + DrainManager.startDrain(io, Math.max(drainPerMin / 60, 4)) # enforce minimum drain rate startDrain: (io, rate) -> # Clear out any old interval