Index: tests/lib/async/future_test.dart |
diff --git a/tests/lib/async/future_test.dart b/tests/lib/async/future_test.dart |
index ae2eaafe539c33ad4706ace8d143d29b04514422..078ee4aa80e3118ba478436530fd6a5bc6f414ff 100644 |
--- a/tests/lib/async/future_test.dart |
+++ b/tests/lib/async/future_test.dart |
@@ -10,8 +10,8 @@ import 'dart:isolate'; |
const Duration MS = const Duration(milliseconds: 1); |
-testImmediate() { |
- final future = new Future<String>.immediate("42"); |
+testValue() { |
+ final future = new Future<String>.value("42"); |
var port = new ReceivePort(); |
future.then((x) { |
Expect.equals("42", x); |
@@ -19,11 +19,11 @@ testImmediate() { |
}); |
} |
-testOf() { |
+testSync() { |
compare(func) { |
// Compare the results of the following two futures. |
- Future f1 = new Future.of(func); |
- Future f2 = new Future.immediate(null).then((_) => func()); |
+ Future f1 = new Future.sync(func); |
+ Future f2 = new Future.value().then((_) => func()); |
f2.catchError((_){}); // I'll get the error later. |
f1.then((v1) { f2.then((v2) { Expect.equals(v1, v2); }); }, |
onError: (e1) { |
@@ -33,17 +33,23 @@ testOf() { |
}); |
}); |
} |
- Future val = new Future.immediate(42); |
- Future err1 = new Future.immediateError("Error")..catchError((_){}); |
+ Future val = new Future.value(42); |
+ Future err1 = new Future.error("Error")..catchError((_){}); |
try { |
throw new List(0); |
} catch (e, st) { |
- Future err2 = new Future.immediateError(e, st)..catchError((_){}); |
+ Future err2 = new Future.error(e, st)..catchError((_){}); |
} |
compare(() => 42); |
compare(() => val); |
compare(() { throw "Flif"; }); |
compare(() => err1); |
+ bool hasExecuted = false; |
+ compare(() { |
+ hasExecuted = true; |
+ return 499; |
+ }); |
+ Expect.isTrue(hasExecuted); |
} |
testNeverComplete() { |
@@ -242,7 +248,7 @@ testFutureAsStreamCompleteBefore() { |
testFutureAsStreamCompleteImmediate() { |
bool gotValue = false; |
var port = new ReceivePort(); |
- new Future.immediate("value").asStream().listen( |
+ new Future.value("value").asStream().listen( |
(data) { |
Expect.isFalse(gotValue); |
gotValue = true; |
@@ -564,7 +570,7 @@ testChainedFutureValue() { |
final future = completer.future; |
var port = new ReceivePort(); |
- future.then((v) => new Future.immediate(v * 2)) |
+ future.then((v) => new Future.value(v * 2)) |
.then((v) { |
Expect.equals(42, v); |
port.close(); |
@@ -600,7 +606,7 @@ testChainedFutureError() { |
final future = completer.future; |
var port = new ReceivePort(); |
- future.then((v) => new Future.immediateError("Fehler")) |
+ future.then((v) => new Future.error("Fehler")) |
.then((v) { Expect.fail("unreachable!"); }, onError: (error) { |
Expect.equals("Fehler", error); |
port.close(); |
@@ -609,8 +615,8 @@ testChainedFutureError() { |
} |
main() { |
- testImmediate(); |
- testOf(); |
+ testValue(); |
+ testSync(); |
testNeverComplete(); |
testComplete(); |