dan/discord.js
1
0
Fork 0
mirror of https://github.com/danbulant/discord.js synced 2026-06-07 08:41:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix #657

Browse source
This commit is contained in:
Amish Shah 2016-09-09 16:22:36 +01:00
parent 8d3018e190
commit 85fae72b7b
2 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
docs/docs.json
View file

File diff suppressed because one or more lines are too long

10
src/client/websocket/WebSocketManager.js
View file

@ -75,7 +75,7 @@ class WebSocketManager {
*/ */
send(data, force = false) { send(data, force = false) {
if (force) { if (force) {
this.ws.send(JSON.stringify(data)); this._send(JSON.stringify(data));
return; return;
} }
this._queue.push(JSON.stringify(data)); this._queue.push(JSON.stringify(data));
@ -88,6 +88,12 @@ class WebSocketManager {
this.status = Constants.Status.IDLE; this.status = Constants.Status.IDLE;
} }
_send(data) {
if (this.ws.readyState === WebSocket.OPEN) {
this.ws.send(data);
}
}
doQueue() { doQueue() {
const item = this._queue[0]; const item = this._queue[0];
if (this.ws.readyState === WebSocket.OPEN && item) { if (this.ws.readyState === WebSocket.OPEN && item) {
@ -98,7 +104,7 @@ class WebSocketManager {
return; return;
} }
this._remaining--; this._remaining--;
this.ws.send(item); this._send(item);
this._queue.shift(); this._queue.shift();
this.doQueue(); this.doQueue();
this.client.setTimeout(() => this._remaining++, 1000); this.client.setTimeout(() => this._remaining++, 1000);