dan/discord.js
1
0
Fork 0
mirror of https://github.com/danbulant/discord.js synced 2026-06-24 17:21:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Webpack build for branch master: 6495df50f9

Browse source
This commit is contained in:
Travis CI 2017-04-11 16:55:12 +00:00
parent a96f7634a6
commit 8a57652d65
2 changed files with 14 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
discord.master.js
View file

@ -16001,7 +16001,6 @@ class RESTManager {
makeRequest(method, url, auth, data, file) { makeRequest(method, url, auth, data, file) {
const apiRequest = new APIRequest(this, method, url, auth, data, file); const apiRequest = new APIRequest(this, method, url, auth, data, file);
if (!this.handlers[apiRequest.route]) { if (!this.handlers[apiRequest.route]) {
const RequestHandlerType = this.getRequestHandler(); const RequestHandlerType = this.getRequestHandler();
this.handlers[apiRequest.route] = new RequestHandlerType(this, apiRequest.route); this.handlers[apiRequest.route] = new RequestHandlerType(this, apiRequest.route);
@ -23262,6 +23261,12 @@ class SequentialRequestHandler extends RequestHandler {
* @type {number} * @type {number}
*/ */
this.timeDifference = 0; this.timeDifference = 0;
/**
* Whether the queue is being processed or not
* @type {boolean}
*/
this.busy = false;
} }
push(request) { push(request) {
@ -23275,6 +23280,7 @@ class SequentialRequestHandler extends RequestHandler {
* @returns {Promise<?Object|Error>} * @returns {Promise<?Object|Error>}
*/ */
execute(item) { execute(item) {
this.busy = true;
return new Promise(resolve => { return new Promise(resolve => {
item.request.gen().end((err, res) => { item.request.gen().end((err, res) => {
if (res && res.headers) { if (res && res.headers) {
@ -23317,8 +23323,11 @@ class SequentialRequestHandler extends RequestHandler {
handle() { handle() {
super.handle(); super.handle();
if (this.remaining === 0 || this.queue.length === 0 || this.globalLimit) return; if (this.busy || this.remaining === 0 || this.queue.length === 0 || this.globalLimit) return;
this.execute(this.queue.shift()).then(() => this.handle()); this.execute(this.queue.shift()).then(() => {
this.busy = false;
this.handle();
});
} }
} }

4
discord.master.min.js vendored
View file

File diff suppressed because one or more lines are too long