build release

dist/commonjs/rsvp/queue.js

@@ -13,7 +13,7 @@ function ResolvedQueueError(message) {
 ResolvedQueueError.prototype = new Error();
 ResolvedQueueError.prototype.constructor = ResolvedQueueError;
 
-var Queue = function() {
+var Queue = function(thenable) {
   var queue = this,
     promise_list = [],
     promise,
@@ -31,6 +31,26 @@ var Queue = function() {
     }
   }
 
+  function checkPromise(next_promise) {
+    promise_list.push(next_promise);
+    // Handle pop
+    promise_list.push(next_promise.then(function (fulfillmentValue) {
+      promise_list.splice(0, 2);
+      if (promise_list.length === 0) {
+        fulfill(fulfillmentValue);
+      } else {
+        return fulfillmentValue;
+      }
+    }, function (rejectedReason) {
+      promise_list.splice(0, 2);
+      if (promise_list.length === 0) {
+        reject(rejectedReason);
+      } else {
+        throw rejectedReason;
+      }
+    }));
+  }
+
   promise = new Promise(function(done, fail) {
     fulfill = function (fulfillmentValue) {
       if (resolved) {return;}
@@ -48,13 +68,7 @@ var Queue = function() {
     };
   }, canceller);
 
-  promise_list.push(resolve());
-  promise_list.push(promise_list[0].then(function () {
-    promise_list.splice(0, 2);
-    if (promise_list.length === 0) {
-      fulfill();
-    }
-  }));
+  checkPromise(resolve(thenable));
 
   queue.cancel = function () {
     if (resolved) {return;}
@@ -77,25 +91,9 @@ var Queue = function() {
       throw new ResolvedQueueError();
     }
 
-    next_promise = last_promise.then(done, fail);
-    promise_list.push(next_promise);
-
     // Handle pop
-    promise_list.push(next_promise.then(function (fulfillmentValue) {
-      promise_list.splice(0, 2);
-      if (promise_list.length === 0) {
-        fulfill(fulfillmentValue);
-      } else {
-        return fulfillmentValue;
-      }
-    }, function (rejectedReason) {
-      promise_list.splice(0, 2);
-      if (promise_list.length === 0) {
-        reject(rejectedReason);
-      } else {
-        throw rejectedReason;
-      }
-    }));
+    checkPromise(last_promise.then(done, fail));
+
 
     return this;
   };

dist/rsvp-2.0.4.amd.js

@@ -724,7 +724,7 @@ define("rsvp/queue",
     ResolvedQueueError.prototype = new Error();
     ResolvedQueueError.prototype.constructor = ResolvedQueueError;
 
-    var Queue = function() {
+    var Queue = function(thenable) {
       var queue = this,
         promise_list = [],
         promise,
@@ -742,6 +742,26 @@ define("rsvp/queue",
         }
       }
 
+      function checkPromise(next_promise) {
+        promise_list.push(next_promise);
+        // Handle pop
+        promise_list.push(next_promise.then(function (fulfillmentValue) {
+          promise_list.splice(0, 2);
+          if (promise_list.length === 0) {
+            fulfill(fulfillmentValue);
+          } else {
+            return fulfillmentValue;
+          }
+        }, function (rejectedReason) {
+          promise_list.splice(0, 2);
+          if (promise_list.length === 0) {
+            reject(rejectedReason);
+          } else {
+            throw rejectedReason;
+          }
+        }));
+      }
+
       promise = new Promise(function(done, fail) {
         fulfill = function (fulfillmentValue) {
           if (resolved) {return;}
@@ -759,13 +779,7 @@ define("rsvp/queue",
         };
       }, canceller);
 
-      promise_list.push(resolve());
-      promise_list.push(promise_list[0].then(function () {
-        promise_list.splice(0, 2);
-        if (promise_list.length === 0) {
-          fulfill();
-        }
-      }));
+      checkPromise(resolve(thenable));
 
       queue.cancel = function () {
         if (resolved) {return;}
@@ -788,25 +802,9 @@ define("rsvp/queue",
           throw new ResolvedQueueError();
         }
 
-        next_promise = last_promise.then(done, fail);
-        promise_list.push(next_promise);
-
         // Handle pop
-        promise_list.push(next_promise.then(function (fulfillmentValue) {
-          promise_list.splice(0, 2);
-          if (promise_list.length === 0) {
-            fulfill(fulfillmentValue);
-          } else {
-            return fulfillmentValue;
-          }
-        }, function (rejectedReason) {
-          promise_list.splice(0, 2);
-          if (promise_list.length === 0) {
-            reject(rejectedReason);
-          } else {
-            throw rejectedReason;
-          }
-        }));
+        checkPromise(last_promise.then(done, fail));
+
 
         return this;
       };

dist/rsvp-2.0.4.js

@@ -761,7 +761,7 @@ define("rsvp/queue",
     ResolvedQueueError.prototype = new Error();
     ResolvedQueueError.prototype.constructor = ResolvedQueueError;
 
-    var Queue = function() {
+    var Queue = function(thenable) {
       var queue = this,
         promise_list = [],
         promise,
@@ -779,6 +779,26 @@ define("rsvp/queue",
         }
       }
 
+      function checkPromise(next_promise) {
+        promise_list.push(next_promise);
+        // Handle pop
+        promise_list.push(next_promise.then(function (fulfillmentValue) {
+          promise_list.splice(0, 2);
+          if (promise_list.length === 0) {
+            fulfill(fulfillmentValue);
+          } else {
+            return fulfillmentValue;
+          }
+        }, function (rejectedReason) {
+          promise_list.splice(0, 2);
+          if (promise_list.length === 0) {
+            reject(rejectedReason);
+          } else {
+            throw rejectedReason;
+          }
+        }));
+      }
+
       promise = new Promise(function(done, fail) {
         fulfill = function (fulfillmentValue) {
           if (resolved) {return;}
@@ -796,13 +816,7 @@ define("rsvp/queue",
         };
       }, canceller);
 
-      promise_list.push(resolve());
-      promise_list.push(promise_list[0].then(function () {
-        promise_list.splice(0, 2);
-        if (promise_list.length === 0) {
-          fulfill();
-        }
-      }));
+      checkPromise(resolve(thenable));
 
       queue.cancel = function () {
         if (resolved) {return;}
@@ -825,25 +839,9 @@ define("rsvp/queue",
           throw new ResolvedQueueError();
         }
 
-        next_promise = last_promise.then(done, fail);
-        promise_list.push(next_promise);
-
         // Handle pop
-        promise_list.push(next_promise.then(function (fulfillmentValue) {
-          promise_list.splice(0, 2);
-          if (promise_list.length === 0) {
-            fulfill(fulfillmentValue);
-          } else {
-            return fulfillmentValue;
-          }
-        }, function (rejectedReason) {
-          promise_list.splice(0, 2);
-          if (promise_list.length === 0) {
-            reject(rejectedReason);
-          } else {
-            throw rejectedReason;
-          }
-        }));
+        checkPromise(last_promise.then(done, fail));
+
 
         return this;
       };