diff --git a/services/real-time/app/coffee/DrainManager.coffee b/services/real-time/app/coffee/DrainManager.coffee index efdd636199..92b59b0751 100644 --- a/services/real-time/app/coffee/DrainManager.coffee +++ b/services/real-time/app/coffee/DrainManager.coffee @@ -19,7 +19,8 @@ module.exports = logger.log {client_id: client.id}, "Asking client to reconnect gracefully" client.emit "reconnectGracefully" drainedCount++ - if drainedCount == N + haveDrainedNClients = (drainedCount == N) + if haveDrainedNClients break if drainedCount < N logger.log "All clients have been told to reconnectGracefully" \ No newline at end of file