@@ -141,8 +141,9 @@ class _IOModule extends CoreClass {
const sockets = [];
if (ns) {
- return async.each(
+ return async.eachLimit(
Object.keys(ns.connected),
+ 1,
(id, next) => {
const { session } = ns.connected[id];
CacheModule.runJob(
@@ -443,7 +443,6 @@ export default {
io.getSocket(socket => {
this.socket = socket;
- io.removeAllListeners();
if (this.socket.connected) this.join();
io.onConnect(this.join);
this.socket.emit("stations.existsByName", this.stationName, res => {