Add canceler to Task.all, and tests. Issue dojo#260.

src/async/Task.ts

@@ -1,7 +1,7 @@
 import { Thenable } from '@dojo/shim/interfaces';
 import { Executor } from '@dojo/shim/Promise';
 import ExtensiblePromise, { ListOfPromises, DictionaryOfPromises, unwrapPromises } from './ExtensiblePromise';
-import { Iterable } from '@dojo/shim/iterator';
+import { Iterable, forOf, isIterable, isArrayLike } from '@dojo/shim/iterator';
 
 /**
  * Describe the internal state of a task.
@@ -149,7 +149,28 @@ export default class Task<T> extends ExtensiblePromise<T> {
 	 * @returns An extensible promise
 	 */
 	static all<T>(iterable: DictionaryOfPromises<T> | ListOfPromises<T>): Task<any> {
-		return super.all(iterable) as Task<any>;
+		return new Task<T>((resolve, reject) => {
+			super.all(iterable).then(<any> resolve, <any> reject);
+		}, () => {
+			if (isIterable(iterable) || isArrayLike(iterable)) {
+				forOf(iterable, (promiseLike: any) => {
+					if (isTask(promiseLike)) {
+						promiseLike.cancel();
+					}
+				});
+			}
+			else {
+				const promiseKeys = Object.keys(iterable);
+
+				promiseKeys.forEach((key: any) => {
+					const promiseLike = iterable[ key ];
+
+					if (isTask(promiseLike)) {
+						promiseLike.cancel();
+					}
+				});
+			}
+		});
 	}
 
 	/**

tests/unit/async/Task.ts

@@ -382,6 +382,46 @@ function addPromiseTests(suite: any, Promise: any) {
 			Promise.all(iterable).then(dfd.callback(function (value: number[]) {
 				assert.notStrictEqual(value, iterable);
 			}));
+		},
+
+		'cancelable': {
+			'isIterable': function (this: any) {
+				let pending: any[] = [];
+
+				for (let i = 0; i < 3; i++) {
+					pending[i] = new Promise(function () {});
+				}
+
+				let tasks = Promise.all(pending);
+
+				tasks.cancel();
+
+				tasks.then(() => {
+					pending.forEach((task) => {
+						assert.strictEqual(task.state, State.Canceled, 'Task should have Canceled state');
+					});
+				});
+			},
+			'isObject': function (this: any) {
+				let pending = <any> {};
+
+				for (let i = 0; i < 3; i++) {
+					pending[i] = new Promise(function () {});
+				}
+
+				let tasks = Promise.all(pending);
+
+				tasks.cancel();
+
+				tasks.then(() => {
+					let keys = Object.keys(pending);
+
+					keys.forEach((key) => {
+						let task = pending[key];
+						assert.strictEqual(task.state, State.Canceled, 'Task should have Canceled state');
+					});
+				});
+			}
 		}
 	};