handle APISocketEvents async
This commit is contained in:
parent
e036042a3d
commit
dc4e57ebaa
|
@ -79,10 +79,10 @@ class APISocketServer {
|
||||||
this.ping = this.ping.bind(this);
|
this.ping = this.ping.bind(this);
|
||||||
this.broadcastChatMessage = this.broadcastChatMessage.bind(this);
|
this.broadcastChatMessage = this.broadcastChatMessage.bind(this);
|
||||||
|
|
||||||
socketEvents.on('broadcast', this.broadcast);
|
socketEvents.onAsync('broadcast', this.broadcast);
|
||||||
socketEvents.on('onlineCounter', this.broadcastOnlineCounter);
|
socketEvents.onAsync('onlineCounter', this.broadcastOnlineCounter);
|
||||||
socketEvents.on('pixelUpdate', this.broadcastPixelBuffer);
|
socketEvents.onAsync('pixelUpdate', this.broadcastPixelBuffer);
|
||||||
socketEvents.on('chatMessage', this.broadcastChatMessage);
|
socketEvents.onAsync('chatMessage', this.broadcastChatMessage);
|
||||||
|
|
||||||
setInterval(this.ping, 45 * 1000);
|
setInterval(this.ping, 45 * 1000);
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,6 +22,17 @@ class SocketEvents extends EventEmitter {
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* async event
|
||||||
|
*/
|
||||||
|
onAsync(evtString, cb) {
|
||||||
|
this.on(evtString, (...args) => {
|
||||||
|
setImmediate(() => {
|
||||||
|
cb(...args);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* broadcast message via websocket
|
* broadcast message via websocket
|
||||||
* @param message Buffer Message to send
|
* @param message Buffer Message to send
|
||||||
|
|
Loading…
Reference in New Issue
Block a user