feat($q): added support to promise notification

src/ng/q.js

@@ -194,7 +194,7 @@ function qFactory(nextTick, exceptionHandler) {
               var callback;
               for (var i = 0, ii = callbacks.length; i < ii; i++) {
                 callback = callbacks[i];
-                value.then(callback[0], callback[1]);
+                value.then(callback[0], callback[1], callback[2]);
               }
             });
           }
@@ -207,8 +207,25 @@ function qFactory(nextTick, exceptionHandler) {
       },
 
 
+      notify: function(progress) {
+        if (pending) {
+          var callbacks = pending;
+
+          if (pending.length) {
+            nextTick(function() {
+              var callback;
+              for (var i = 0, ii = callbacks.length; i < ii; i++) {
+                callback = callbacks[i];
+                callback[2](progress);
+              }
+            });
+          }
+        }
+      },
+
+
       promise: {
-        then: function(callback, errback) {
+        then: function(callback, errback, progressback) {
           var result = defer();
 
           var wrappedCallback = function(value) {
@@ -229,10 +246,18 @@ function qFactory(nextTick, exceptionHandler) {
             }
           };
 
+          var wrappedProgressback = function(progress) {
+            try {
+              result.notify((progressback || defaultCallback)(progress));
+            } catch(e) {
+              exceptionHandler(e);
+            }
+          };
+
           if (pending) {
-            pending.push([wrappedCallback, wrappedErrback]);
+            pending.push([wrappedCallback, wrappedErrback, wrappedProgressback]);
           } else {
-            value.then(wrappedCallback, wrappedErrback);
+            value.then(wrappedCallback, wrappedErrback, wrappedProgressback);
           }
 
           return result.promise;
@@ -321,7 +346,7 @@ function qFactory(nextTick, exceptionHandler) {
    *   the promises is resolved with a rejection, this resulting promise will be resolved with the
    *   same rejection.
    */
-  var when = function(value, callback, errback) {
+  var when = function(value, callback, errback, progressback) {
     var result = defer(),
         done;
 
@@ -343,15 +368,26 @@ function qFactory(nextTick, exceptionHandler) {
       }
     };
 
+    var wrappedProgressback = function(progress) {
+      try {
+        return (progressback || defaultCallback)(progress);
+      } catch (e) {
+        exceptionHandler(e);
+      }
+    };
+
     nextTick(function() {
       ref(value).then(function(value) {
         if (done) return;
         done = true;
-        result.resolve(ref(value).then(wrappedCallback, wrappedErrback));
+        result.resolve(ref(value).then(wrappedCallback, wrappedErrback, wrappedProgressback));
       }, function(reason) {
         if (done) return;
         done = true;
         result.resolve(wrappedErrback(reason));
+      }, function(progress) {
+        if (done) return;
+        result.notify(wrappedProgressback(progress));
       });
     });
 
@@ -386,7 +422,9 @@ function qFactory(nextTick, exceptionHandler) {
   function all(promises) {
     var deferred = defer(),
         counter = 0,
-        results = isArray(promises) ? [] : {};
+        results = isArray(promises) ? [] : {},
+        notifications = isArray(promises) ? [] : {},
+        notifying;
 
     forEach(promises, function(promise, key) {
       counter++;
@@ -397,6 +435,16 @@ function qFactory(nextTick, exceptionHandler) {
       }, function(reason) {
         if (results.hasOwnProperty(key)) return;
         deferred.reject(reason);
+      }, function(progress) {
+        notifications[key] = progress;
+        if (!notifying) {
+          notifying = true;
+          nextTick(function() {
+            deferred.notify(notifications);
+            notifications = isArray(promises) ? [] : {};
+            notifying = false;
+          });
+        }
       });
     });