Re-submit r18349.

pkg/scheduled_test/test/scheduled_test_test.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library scheduled_test_test;
 
 import 'dart:async';
 
 import 'package:scheduled_test/scheduled_test.dart';
 import 'package:scheduled_test/src/utils.dart';
@@ skipping 77 matching lines @@
     test('asynchronous value', () {
       var future = schedule(() => new Future.immediate('value'));
       expect(future, completion(equals('value')));
     });
   });
 
   expectTestsPass('scheduled blocks should wait for their Future return values '
       'to complete before proceeding', () {
     test('test', () {
       var value = 'unset';
-      schedule(() => sleep(500).then((_) {
+      schedule(() => sleep(50).then((_) {
         value = 'set';
       }));
       schedule(() => expect(value, equals('set')));
     });
   });
 
   expectTestsFail('a test failure in a chained future in a scheduled block '
       'should be registered', () {
     test('test', () {
       schedule(() => new Future.immediate('foo')
@@ skipping 177 matching lines @@
       });
 
       sleep(50).then(wrapAsync((_) => expect('foo', equals('bar'))));
     });
 
     test('test 2', () {
       expect(onCompleteRun, isTrue);
     });
   }, passing: ['test 2']);
 
-  expectTestsPass('currentSchedule.error contains the error in the onComplete '
+  expectTestsPass('currentSchedule.errors contains the error in the onComplete '
       'queue', () {
-    var error;
+    var errors;
     test('test 1', () {
       currentSchedule.onComplete.schedule(() {
-        error = currentSchedule.error;
+        errors = currentSchedule.errors;
       });
 
       throw 'error';
     });
 
     test('test 2', () {
-      expect(error, new isInstanceOf<ScheduleError>());
-      expect(error.error, equals('error'));
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['error']));
     });
   }, passing: ['test 2']);
 
   expectTestsPass('onComplete tasks can be scheduled during normal tasks', () {
     var onCompleteRun = false;
     test('test 1', () {
       schedule(() {
         currentSchedule.onComplete.schedule(() {
           onCompleteRun = true;
         });
@@ skipping 68 matching lines @@
       });
 
       sleep(50).then(wrapAsync((_) => expect('foo', equals('bar'))));
     });
 
     test('test 2', () {
       expect(onExceptionRun, isTrue);
     });
   }, passing: ['test 2']);
 
-  expectTestsPass('currentSchedule.error contains the error in the onException '
-      'queue', () {
-    var error;
+  expectTestsPass('currentSchedule.errors contains the error in the '
+      'onException queue', () {
+    var errors;
     test('test 1', () {
       currentSchedule.onException.schedule(() {
-        error = currentSchedule.error;
+        errors = currentSchedule.errors;
       });
 
       throw 'error';
     });
 
     test('test 2', () {
-      expect(error, new isInstanceOf<ScheduleError>());
-      expect(error.error, equals('error'));
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['error']));
     });
   }, passing: ['test 2']);
 
-  expectTestsPass('currentSchedule.error contains an error passed into '
+  expectTestsPass('currentSchedule.errors contains an error passed into '
       'signalError synchronously', () {
-    var error;
+    var errors;
     test('test 1', () {
       currentSchedule.onException.schedule(() {
-        error = currentSchedule.error;
+        errors = currentSchedule.errors;
       });
 
       currentSchedule.signalError('error');
     });
 
     test('test 2', () {
-      expect(error, new isInstanceOf<ScheduleError>());
-      expect(error.error, equals('error'));
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['error']));
     });
   }, passing: ['test 2']);
 
-  expectTestsPass('currentSchedule.error contains an error passed into '
+  expectTestsPass('currentSchedule.errors contains an error passed into '
       'signalError asynchronously', () {
-    var error;
+    var errors;
     test('test 1', () {
       currentSchedule.onException.schedule(() {
-        error = currentSchedule.error;
+        errors = currentSchedule.errors;
       });
 
       schedule(() => currentSchedule.signalError('error'));
     });
 
     test('test 2', () {
-      expect(error, new isInstanceOf<ScheduleError>());
-      expect(error.error, equals('error'));
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['error']));
     });
   }, passing: ['test 2']);
 
-  expectTestsPass('currentSchedule.error contains an error passed into '
+  expectTestsPass('currentSchedule.errors contains an error passed into '
       'signalError out-of-band', () {
-    var error;
+    var errors;
     test('test 1', () {
       currentSchedule.onException.schedule(() {
-        error = currentSchedule.error;
+        errors = currentSchedule.errors;
       });
 
       sleep(50).then(wrapAsync((_) => currentSchedule.signalError('error')));
     });
 
     test('test 2', () {
-      expect(error, new isInstanceOf<ScheduleError>());
-      expect(error.error, equals('error'));
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['error']));
     });
   }, passing: ['test 2']);
 
+  expectTestsPass('currentSchedule.errors contains errors from both the task '
+      'queue and the onException queue in onComplete', () {
+    var errors;
+    test('test 1', () {
+      currentSchedule.onComplete.schedule(() {
+        errors = currentSchedule.errors;
+      });
+
+      currentSchedule.onException.schedule(() {
+        throw 'error2';
+      });
+
+      throw 'error1';
+    });
+
+    test('test 2', () {
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['error1', 'error2']));
+    });
+  }, passing: ['test 2']);
+
+  expectTestsPass('currentSchedule.errors contains multiple out-of-band errors '
+      'from both the main task queue and onException in onComplete', () {
+    var errors;
+    test('test 1', () {
+      currentSchedule.onComplete.schedule(() {
+        errors = currentSchedule.errors;
+      });
+
+      currentSchedule.onException.schedule(() {
+        sleep(25).then(wrapAsync((_) {
+          throw 'error3';
+        }));
+        sleep(50).then(wrapAsync((_) {
+          throw 'error4';
+        }));
+      });
+
+      sleep(25).then(wrapAsync((_) {
+        throw 'error1';
+      }));
+      sleep(50).then(wrapAsync((_) {
+        throw 'error2';
+      }));
+    });
+
+    test('test 2', () {
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error),
+          orderedEquals(['error1', 'error2', 'error3', 'error4']));
+    });
+  }, passing: ['test 2']);
+
+  expectTestsPass('currentSchedule.errors contains both an out-of-band error '
+      'and an error raised afterwards in a task', () {
+    var errors;
+    test('test 1', () {
+      currentSchedule.onComplete.schedule(() {
+        errors = currentSchedule.errors;
+      });
+
+      sleep(25).then(wrapAsync((_) {
+        throw 'out-of-band';
+      }));
+
+      schedule(() => sleep(50).then((_) {
+        throw 'in-band';
+      }));
+    });
+
+    test('test 2', () {
+      expect(errors, everyElement(new isInstanceOf<ScheduleError>()));
+      expect(errors.map((e) => e.error), equals(['out-of-band', 'in-band']));
+    });
+  }, passing: ['test 2']);
+
   expectTestsPass('currentSchedule.currentTask returns the current task while '
       'executing a task', () {
     test('test', () {
       schedule(() => expect('foo', equals('foo')), 'task 1');
 
       schedule(() {
         expect(currentSchedule.currentTask.description, equals('task 2'));
       }, 'task 2');
 
       schedule(() => expect('bar', equals('bar')), 'task 3');
     });
   });
 
   expectTestsPass('currentSchedule.currentTask is null before the schedule has '
       'started', () {
     test('test', () {
       schedule(() => expect('foo', equals('foo')));
 
       expect(currentSchedule.currentTask, isNull);
     });
   });
 
   expectTestsPass('currentSchedule.currentTask is null after the schedule has '
       'completed', () {
     test('test', () {
-      expect(sleep(50).then((_) {
-        expect(currentSchedule.currentTask, isNull);
-      }), completes);
+      schedule(() {
+        expect(sleep(50).then((_) {
+          expect(currentSchedule.currentTask, isNull);
+        }), completes);
+      });
 
       schedule(() => expect('foo', equals('foo')));
     });
   });
 
   expectTestsPass('currentSchedule.currentQueue returns the current queue while '
       'executing a task', () {
     test('test', () {
       schedule(() {
         expect(currentSchedule.currentQueue.name, equals('tasks'));
@@ skipping 131 matching lines @@
       });
     });
 
     group('group 2', () {
       test('test 2', () {
         expect(setUpRun, isFalse);
       });
     });
   });
 }