ashanbrown · August 29, 2015 14:02 · Jul 21, 2014 · Jun 9, 2014 · Jun 9, 2014 · Jun 5, 2014
diff --git a/jquery.ajax.queue.coffee b/jquery.ajax.queue.coffee
@@ -41,7 +41,7 @@ remove = (name, options) ->
   list = queue(name)
 
   for [value, _], i in list.entries when value is options
-    list.splice(i, 1)
+    list.entries.splice(i, 1)
     break
 
 $.ajaxTransport '+*', (options) ->

diff --git a/jquery.ajax.queue.coffee b/jquery.ajax.queue.coffee
@@ -10,7 +10,7 @@ next = (name, done) ->
   list = queue(name)
 
   if done
-    queues(name).running--
+    queue(name).running--
 
   unless list.entries.length
     return
@@ -22,7 +22,7 @@ next = (name, done) ->
 
   list.entries.shift()
 
-  queues(name).running++
+  queue(name).running++
 
   $.ajax(options)
   .always(-> next(name, true))

diff --git a/jquery.ajax.queue.coffee b/jquery.ajax.queue.coffee
@@ -10,7 +10,7 @@ next = (name, done) ->
   list = queue(name)
 
   if done
-    queues[name].running--
+    queues(name).running--
 
   unless list.entries.length
     return
@@ -22,7 +22,7 @@ next = (name, done) ->
 
   list.entries.shift()
 
-  queues[name].running++
+  queues(name).running++
 
   $.ajax(options)
   .always(-> next(name, true))

diff --git a/jquery.ajax.queue.coffee b/jquery.ajax.queue.coffee
@@ -1,39 +1,46 @@
 $ = jQuery
 
 queues  = {}
-running = false
 
 queue = (name) ->
   name = 'default' if name is true
-  queues[name] or= []
+  queues[name] or= {entries: [], running: 0}
 
-next = (name) ->
+next = (name, done) ->
   list = queue(name)
 
-  unless list.length
-    running = false
+  if done
+    queues[name].running--
+
+  unless list.entries.length
+    return
+
+  [options, deferred] = list.entries[0]
+
+  if list.running >= (options.queueMaxConcurrency || 1)
     return
 
-  [options, deferred] = list.shift()
+  list.entries.shift()
+
+  queues[name].running++
 
   $.ajax(options)
-    .always(-> next(name))
-    .done(-> deferred.resolve(arguments...))
-    .fail(-> deferred.reject(arguments...))
+  .always(-> next(name, true))
+  .done(-> deferred.resolve(arguments...))
+  .fail(-> deferred.reject(arguments...))
 
 push = (name, options) ->
   list = queue(name)
   deferred = $.Deferred()
 
-  list.push([options, deferred])
-  next(name) unless running
-  running = true
+  list.entries.push([options, deferred])
+  next(name)
   deferred.promise()
 
 remove = (name, options) ->
   list = queue(name)
 
-  for [value, _], i in list when value is options
+  for [value, _], i in list.entries when value is options
     list.splice(i, 1)
     break
 
@@ -45,17 +52,17 @@ $.ajaxTransport '+*', (options) ->
 
     send: (headers, complete) ->
       push(options.queue, queuedOptions)
-        .done (data, textStatus, jqXHR) ->
-          complete(jqXHR.status,
-                   jqXHR.statusText,
-                   text: jqXHR.responseText,
-                   jqXHR.getAllResponseHeaders())
-
-        .fail (jqXHR, textStatus, errorThrown) ->
-          complete(jqXHR.status,
-                   jqXHR.statusText,
-                   text: jqXHR.responseText,
-                   jqXHR.getAllResponseHeaders())
+      .done (data, textStatus, jqXHR) ->
+        complete(jqXHR.status,
+          jqXHR.statusText,
+          text: jqXHR.responseText,
+          jqXHR.getAllResponseHeaders())
+
+      .fail (jqXHR, textStatus, errorThrown) ->
+        complete(jqXHR.status,
+          jqXHR.statusText,
+          text: jqXHR.responseText,
+          jqXHR.getAllResponseHeaders())
 
     abort: ->
       remove(options.queue, queuedOptions)
diff --git a/jquery.ajax.queue.coffee b/jquery.ajax.queue.coffee
@@ -19,7 +19,7 @@ next = (name) ->
   $.ajax(options)
     .always(-> next(name))
     .done(-> deferred.resolve(arguments...))
-    .fail(-> deferred.error(arguments...))
+    .fail(-> deferred.reject(arguments...))
 
 push = (name, options) ->
   list = queue(name)

diff --git a/jquery.ajax.queue.js b/jquery.ajax.queue.js
@@ -29,7 +29,7 @@
     }).done(function() {
       return deferred.resolve.apply(deferred, arguments);
     }).fail(function() {
-      return deferred.error.apply(deferred, arguments);
+      return deferred.reject.apply(deferred, arguments);
     });
   };
 

diff --git a/jquery.ajax.queue.js b/jquery.ajax.queue.js
@@ -1,83 +1,91 @@
-var $, next, push, queue, queues, remove, running;
+// Generated by CoffeeScript 1.6.2
+(function() {
+  var $, next, push, queue, queues, remove, running;
 
-$ = jQuery;
+  $ = jQuery;
 
-queues = {};
+  queues = {};
 
-running = false;
+  running = false;
 
-queue = function(name) {
-  if (name === true) {
-    name = 'default';
-  }
-  return queues[name] || (queues[name] = []);
-};
+  queue = function(name) {
+    if (name === true) {
+      name = 'default';
+    }
+    return queues[name] || (queues[name] = []);
+  };
 
-next = function(name) {
-  var deferred, list, options, _ref;
-  list = queue(name);
-  if (!list.length) {
-    running = false;
-    return;
-  }
-  _ref = list.shift(), options = _ref[0], deferred = _ref[1];
-  return $.ajax(options).always(function() {
-    return next(name);
-  }).done(function() {
-    return deferred.resolve.apply(deferred, arguments);
-  }).fail(function() {
-    return deferred.error.apply(deferred, arguments);
-  });
-};
+  next = function(name) {
+    var deferred, list, options, _ref;
+
+    list = queue(name);
+    if (!list.length) {
+      running = false;
+      return;
+    }
+    _ref = list.shift(), options = _ref[0], deferred = _ref[1];
+    return $.ajax(options).always(function() {
+      return next(name);
+    }).done(function() {
+      return deferred.resolve.apply(deferred, arguments);
+    }).fail(function() {
+      return deferred.error.apply(deferred, arguments);
+    });
+  };
 
-push = function(name, options) {
-  var deferred, list;
-  list = queue(name);
-  deferred = $.Deferred();
-  list.push([options, deferred]);
-  if (!running) {
-    next(name);
-  }
-  running = true;
-  return deferred.promise();
-};
+  push = function(name, options) {
+    var deferred, list;
 
-remove = function(name, options) {
-  var i, list, value, _, _i, _len, _ref, _results;
-  list = queue(name);
-  _results = [];
-  for (i = _i = 0, _len = list.length; _i < _len; i = ++_i) {
-    _ref = list[i], value = _ref[0], _ = _ref[1];
-    if (!(value === options)) {
-      continue;
+    list = queue(name);
+    deferred = $.Deferred();
+    list.push([options, deferred]);
+    if (!running) {
+      next(name);
     }
-    list.splice(i, 1);
-    break;
-  }
-  return _results;
-};
+    running = true;
+    return deferred.promise();
+  };
+
+  remove = function(name, options) {
+    var i, list, value, _, _i, _len, _ref, _results;
 
-$.ajaxTransport('+*', function(options) {
-  var queuedOptions;
-  if (options.queue) {
-    queuedOptions = $.extend({}, options);
-    queuedOptions.queue = false;
-    queuedOptions.processData = false;
-    return {
-      send: function(headers, complete) {
-        return push(options.queue, queuedOptions).done(function(data, textStatus, jqXHR) {
-          return complete(jqXHR.status, jqXHR.statusText, {
-            text: jqXHR.responseText
-          }, jqXHR.getAllResponseHeaders());
-        }).fail(function(jqXHR, textStatus, errorThrown) {
-          return complete(jqXHR.status, jqXHR.statusText, {
-            text: jqXHR.responseText
-          }, jqXHR.getAllResponseHeaders());
-        });
-      },
-      abort: function() {
-        return remove(options.queue, queuedOptions);
+    list = queue(name);
+    _results = [];
+    for (i = _i = 0, _len = list.length; _i < _len; i = ++_i) {
+      _ref = list[i], value = _ref[0], _ = _ref[1];
+      if (!(value === options)) {
+        continue;
       }
-    };
-  }
-});
+      list.splice(i, 1);
+      break;
+    }
+    return _results;
+  };
+
+  $.ajaxTransport('+*', function(options) {
+    var queuedOptions;
+
+    if (options.queue) {
+      queuedOptions = $.extend({}, options);
+      queuedOptions.queue = false;
+      queuedOptions.processData = false;
+      return {
+        send: function(headers, complete) {
+          return push(options.queue, queuedOptions).done(function(data, textStatus, jqXHR) {
+            return complete(jqXHR.status, jqXHR.statusText, {
+              text: jqXHR.responseText
+            }, jqXHR.getAllResponseHeaders());
+          }).fail(function(jqXHR, textStatus, errorThrown) {
+            return complete(jqXHR.status, jqXHR.statusText, {
+              text: jqXHR.responseText
+            }, jqXHR.getAllResponseHeaders());
+          });
+        },
+        abort: function() {
+          return remove(options.queue, queuedOptions);
+        }
+      };
+    }
+  });
+
+}).call(this);
diff --git a/jquery.ajax.queue.coffee b/jquery.ajax.queue.coffee
@@ -0,0 +1,61 @@
+$ = jQuery
+
+queues  = {}
+running = false
+
+queue = (name) ->
+  name = 'default' if name is true
+  queues[name] or= []
+
+next = (name) ->
+  list = queue(name)
+
+  unless list.length
+    running = false
+    return
+
+  [options, deferred] = list.shift()
+
+  $.ajax(options)
+    .always(-> next(name))
+    .done(-> deferred.resolve(arguments...))
+    .fail(-> deferred.error(arguments...))
+
+push = (name, options) ->
+  list = queue(name)
+  deferred = $.Deferred()
+
+  list.push([options, deferred])
+  next(name) unless running
+  running = true
+  deferred.promise()
+
+remove = (name, options) ->
+  list = queue(name)
+
+  for [value, _], i in list when value is options
+    list.splice(i, 1)
+    break
+
+$.ajaxTransport '+*', (options) ->
+  if options.queue
+    queuedOptions = $.extend({}, options)
+    queuedOptions.queue = false
+    queuedOptions.processData = false
+
+    send: (headers, complete) ->
+      push(options.queue, queuedOptions)
+        .done (data, textStatus, jqXHR) ->
+          complete(jqXHR.status,
+                   jqXHR.statusText,
+                   text: jqXHR.responseText,
+                   jqXHR.getAllResponseHeaders())
+
+        .fail (jqXHR, textStatus, errorThrown) ->
+          complete(jqXHR.status,
+                   jqXHR.statusText,
+                   text: jqXHR.responseText,
+                   jqXHR.getAllResponseHeaders())
+
+    abort: ->
+      remove(options.queue, queuedOptions)
diff --git a/jquery.ajax.queue.js b/jquery.ajax.queue.js
@@ -0,0 +1,83 @@
+var $, next, push, queue, queues, remove, running;
+
+$ = jQuery;
+
+queues = {};
+
+running = false;
+
+queue = function(name) {
+  if (name === true) {
+    name = 'default';
+  }
+  return queues[name] || (queues[name] = []);
+};
+
+next = function(name) {
+  var deferred, list, options, _ref;
+  list = queue(name);
+  if (!list.length) {
+    running = false;
+    return;
+  }
+  _ref = list.shift(), options = _ref[0], deferred = _ref[1];
+  return $.ajax(options).always(function() {
+    return next(name);
+  }).done(function() {
+    return deferred.resolve.apply(deferred, arguments);
+  }).fail(function() {
+    return deferred.error.apply(deferred, arguments);
+  });
+};
+
+push = function(name, options) {
+  var deferred, list;
+  list = queue(name);
+  deferred = $.Deferred();
+  list.push([options, deferred]);
+  if (!running) {
+    next(name);
+  }
+  running = true;
+  return deferred.promise();
+};
+
+remove = function(name, options) {
+  var i, list, value, _, _i, _len, _ref, _results;
+  list = queue(name);
+  _results = [];
+  for (i = _i = 0, _len = list.length; _i < _len; i = ++_i) {
+    _ref = list[i], value = _ref[0], _ = _ref[1];
+    if (!(value === options)) {
+      continue;
+    }
+    list.splice(i, 1);
+    break;
+  }
+  return _results;
+};
+
+$.ajaxTransport('+*', function(options) {
+  var queuedOptions;
+  if (options.queue) {
+    queuedOptions = $.extend({}, options);
+    queuedOptions.queue = false;
+    queuedOptions.processData = false;
+    return {
+      send: function(headers, complete) {
+        return push(options.queue, queuedOptions).done(function(data, textStatus, jqXHR) {
+          return complete(jqXHR.status, jqXHR.statusText, {
+            text: jqXHR.responseText
+          }, jqXHR.getAllResponseHeaders());
+        }).fail(function(jqXHR, textStatus, errorThrown) {
+          return complete(jqXHR.status, jqXHR.statusText, {
+            text: jqXHR.responseText
+          }, jqXHR.getAllResponseHeaders());
+        });
+      },
+      abort: function() {
+        return remove(options.queue, queuedOptions);
+      }
+    };
+  }
+});