| Index: tests/lib_strong/async/futures_test.dart
|
| diff --git a/tests/lib_strong/async/futures_test.dart b/tests/lib_strong/async/futures_test.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..6d6037216719ce8f0dbf952963710aa036a9e0f3
|
| --- /dev/null
|
| +++ b/tests/lib_strong/async/futures_test.dart
|
| @@ -0,0 +1,262 @@
|
| +// Copyright (c) 2011, 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 futures_test;
|
| +import 'package:async_helper/async_helper.dart';
|
| +import "package:expect/expect.dart";
|
| +import 'dart:async';
|
| +
|
| +Future testWaitEmpty() {
|
| + List<Future> futures = new List<Future>();
|
| + return Future.wait(futures);
|
| +}
|
| +
|
| +Future testCompleteAfterWait() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer<Object> c = new Completer<Object>();
|
| + futures.add(c.future);
|
| + Future future = Future.wait(futures);
|
| + c.complete(null);
|
| + return future;
|
| +}
|
| +
|
| +Future testCompleteBeforeWait() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c = new Completer();
|
| + futures.add(c.future);
|
| + c.complete(null);
|
| + return Future.wait(futures);
|
| +}
|
| +
|
| +Future testWaitWithMultipleValues() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.complete(1);
|
| + c2.complete(2);
|
| + return Future.wait(futures).then((values) {
|
| + Expect.listEquals([1, 2], values);
|
| + });
|
| +}
|
| +
|
| +Future testWaitWithSingleError() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.complete();
|
| + c2.completeError('correct error');
|
| +
|
| + return Future.wait(futures).then((_) {
|
| + throw 'incorrect error';
|
| + }).catchError((error, stackTrace) {
|
| + Expect.equals('correct error', error);
|
| + Expect.isNull(stackTrace);
|
| + });
|
| +}
|
| +
|
| +Future testWaitWithMultipleErrors() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.completeError('correct error');
|
| + c2.completeError('incorrect error 1');
|
| +
|
| + return Future.wait(futures).then((_) {
|
| + throw 'incorrect error 2';
|
| + }).catchError((error, stackTrace) {
|
| + Expect.equals('correct error', error);
|
| + Expect.isNull(stackTrace);
|
| + });
|
| +}
|
| +
|
| +Future testWaitWithMultipleErrorsEager() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.completeError('correct error');
|
| + c2.completeError('incorrect error 1');
|
| +
|
| + return Future.wait(futures, eagerError: true).then((_) {
|
| + throw 'incorrect error 2';
|
| + }).catchError((error, stackTrace) {
|
| + Expect.equals('correct error', error);
|
| + Expect.isNull(stackTrace);
|
| + });
|
| +}
|
| +
|
| +StackTrace get currentStackTrace {
|
| + try {
|
| + throw 0;
|
| + } catch(e, st) {
|
| + return st;
|
| + }
|
| + return null;
|
| +}
|
| +
|
| +Future testWaitWithSingleErrorWithStackTrace() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.complete();
|
| + c2.completeError('correct error', currentStackTrace);
|
| +
|
| + return Future.wait(futures).then((_) {
|
| + throw 'incorrect error';
|
| + }).catchError((error, stackTrace) {
|
| + Expect.equals('correct error', error);
|
| + Expect.isNotNull(stackTrace);
|
| + });
|
| +}
|
| +
|
| +Future testWaitWithMultipleErrorsWithStackTrace() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.completeError('correct error', currentStackTrace);
|
| + c2.completeError('incorrect error 1');
|
| +
|
| + return Future.wait(futures).then((_) {
|
| + throw 'incorrect error 2';
|
| + }).catchError((error, stackTrace) {
|
| + Expect.equals('correct error', error);
|
| + Expect.isNotNull(stackTrace);
|
| + });
|
| +}
|
| +
|
| +Future testWaitWithMultipleErrorsWithStackTraceEager() {
|
| + List<Future> futures = new List<Future>();
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + futures.add(c1.future);
|
| + futures.add(c2.future);
|
| + c1.completeError('correct error', currentStackTrace);
|
| + c2.completeError('incorrect error 1');
|
| +
|
| + return Future.wait(futures, eagerError: true).then((_) {
|
| + throw 'incorrect error 2';
|
| + }).catchError((error, stackTrace) {
|
| + Expect.equals('correct error', error);
|
| + Expect.isNotNull(stackTrace);
|
| + });
|
| +}
|
| +
|
| +Future testEagerWait() {
|
| + var st;
|
| + try { throw 0; } catch (e, s) { st = s; }
|
| + Completer c1 = new Completer();
|
| + Completer c2 = new Completer();
|
| + List<Future> futures = <Future>[c1.future, c2.future];
|
| + Future waited = Future.wait(futures, eagerError: true);
|
| + var result = waited.then((v) { throw "should not be called"; },
|
| + onError: (e, s) {
|
| + Expect.equals(e, 42);
|
| + Expect.identical(st, s);
|
| + return true;
|
| + });
|
| + c1.completeError(42, st);
|
| + return result;
|
| +}
|
| +
|
| +Future testForEachEmpty() {
|
| + return Future.forEach([], (_) {
|
| + throw 'should not be called';
|
| + });
|
| +}
|
| +
|
| +Future testForEach() {
|
| + var seen = <int>[];
|
| + return Future.forEach([1, 2, 3, 4, 5], (n) {
|
| + seen.add(n);
|
| + return new Future.value();
|
| + }).then((_) => Expect.listEquals([1, 2, 3, 4, 5], seen));
|
| +}
|
| +
|
| +Future testForEachSync() {
|
| + var seen = <int>[];
|
| + return Future.forEach([1, 2, 3, 4, 5], seen.add)
|
| + .then((_) => Expect.listEquals([1, 2, 3, 4, 5], seen));
|
| +}
|
| +
|
| +Future testForEachWithException() {
|
| + var seen = <int>[];
|
| + return Future.forEach([1, 2, 3, 4, 5], (n) {
|
| + if (n == 4) throw 'correct exception';
|
| + seen.add(n);
|
| + return new Future.value();
|
| + }).then((_) {
|
| + throw 'incorrect exception';
|
| + }).catchError((error) {
|
| + Expect.equals('correct exception', error);
|
| + });
|
| +}
|
| +
|
| +Future testDoWhile() {
|
| + var count = 0;
|
| + return Future.doWhile(() {
|
| + count++;
|
| + return new Future(() => count < 10);
|
| + }).then((_) => Expect.equals(10, count));
|
| +}
|
| +
|
| +Future testDoWhileSync() {
|
| + var count = 0;
|
| + return Future.doWhile(() {
|
| + count++;
|
| + return count < 10;
|
| + }).then((_) => Expect.equals(10, count));
|
| +}
|
| +
|
| +Future testDoWhileWithException() {
|
| + var count = 0;
|
| + return Future.doWhile(() {
|
| + count++;
|
| + if (count == 4) throw 'correct exception';
|
| + return new Future(() => true);
|
| + }).then((_) {
|
| + throw 'incorrect exception';
|
| + }).catchError((error) {
|
| + Expect.equals('correct exception', error);
|
| + });
|
| +}
|
| +
|
| +main() {
|
| + List<Future> futures = new List<Future>();
|
| +
|
| + futures.add(testWaitEmpty());
|
| + futures.add(testCompleteAfterWait());
|
| + futures.add(testCompleteBeforeWait());
|
| + futures.add(testWaitWithMultipleValues());
|
| + futures.add(testWaitWithSingleError());
|
| + futures.add(testWaitWithMultipleErrors());
|
| + futures.add(testWaitWithMultipleErrorsEager());
|
| + futures.add(testWaitWithSingleErrorWithStackTrace());
|
| + futures.add(testWaitWithMultipleErrorsWithStackTrace());
|
| + futures.add(testWaitWithMultipleErrorsWithStackTraceEager());
|
| + futures.add(testEagerWait());
|
| + futures.add(testForEachEmpty());
|
| + futures.add(testForEach());
|
| + futures.add(testForEachSync());
|
| + futures.add(testForEachWithException());
|
| + futures.add(testDoWhile());
|
| + futures.add(testDoWhileSync());
|
| + futures.add(testDoWhileWithException());
|
| +
|
| + asyncStart();
|
| + Future.wait(futures).then((List list) {
|
| + Expect.equals(18, list.length);
|
| + asyncEnd();
|
| + });
|
| +}
|
|
|